rectifier: add PUB zmq socket

[loctrkd.git] / loctrkd / rectifier.py

diff --git a/loctrkd/rectifier.py b/loctrkd/rectifier.py
index 5919cbd2bd9c69437c052eff97d75b157eb3b050..8ee75970aec030f771ec0555ba306ad68b1a3397 100644 (file)
--- 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()