X-Git-Url: http://www.average.org/gitweb/?p=loctrkd.git;a=blobdiff_plain;f=loctrkd%2Frectifier.py;h=8ee75970aec030f771ec0555ba306ad68b1a3397;hp=5919cbd2bd9c69437c052eff97d75b157eb3b050;hb=16bea55924c0ab9d035f3e99573fc49c370de231;hpb=9bf81b19b7b790bc2115ac08dc1f3c112aede976 diff --git a/loctrkd/rectifier.py b/loctrkd/rectifier.py index 5919cbd..8ee7597 100644 --- a/loctrkd/rectifier.py +++ b/loctrkd/rectifier.py @@ -25,6 +25,8 @@ def runserver(conf: ConfigParser) -> None: zsub.setsockopt(zmq.SUBSCRIBE, topic(proto_name(WIFI_POSITIONING))) zpush = zctx.socket(zmq.PUSH) # type: ignore zpush.connect(conf.get("collector", "listenurl")) + zpub = zctx.socket(zmq.PUB) # type: ignore + zpub.connect(conf.get("rectifier", "publishurl")) try: while True: @@ -53,6 +55,7 @@ def runserver(conf: ConfigParser) -> None: except KeyboardInterrupt: zsub.close() + zpub.close() zpush.close() zctx.destroy() # type: ignore qry.shut()