X-Git-Url: http://average.org/gitweb/?a=blobdiff_plain;f=loctrkd%2Frectifier.py;h=8ee75970aec030f771ec0555ba306ad68b1a3397;hb=16bea55924c0ab9d035f3e99573fc49c370de231;hp=5ef6d35f77c32d79c2f696ceb032be08f1cb7231;hpb=5bd4b1bad2506f2f5f71161ac9e8a9b141e0fef4;p=loctrkd.git diff --git a/loctrkd/rectifier.py b/loctrkd/rectifier.py index 5ef6d35..8ee7597 100644 --- a/loctrkd/rectifier.py +++ b/loctrkd/rectifier.py @@ -16,7 +16,7 @@ log = getLogger("loctrkd/rectifier") def runserver(conf: ConfigParser) -> None: - qry = import_module("." + conf.get("rectifier", "backend"), __package__) + qry = import_module("." + conf.get("rectifier", "lookaside"), __package__) qry.init(conf) # Is this https://github.com/zeromq/pyzmq/issues/1627 still not fixed?! zctx = zmq.Context() # type: ignore @@ -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()