X-Git-Url: http://www.average.org/gitweb/?p=loctrkd.git;a=blobdiff_plain;f=gps303%2Flookaside.py;h=0c1e4cdcf19e8ca0b22c8b73615bfa178939b313;hp=1d214896b81fc5e3c73db89fa6a68c9a10412d88;hb=c3bc6d5bbdc0d0bf10e338c6e3bad1a519d5afa0;hpb=d6d5b6c95b677d98777959040bac808e4c5499c7 diff --git a/gps303/lookaside.py b/gps303/lookaside.py index 1d21489..0c1e4cd 100644 --- a/gps303/lookaside.py +++ b/gps303/lookaside.py @@ -9,7 +9,7 @@ from struct import pack import zmq from . import common -from .gps303proto import parse_message, WIFI_POSITIONING +from .gps303proto import parse_message, proto_name, WIFI_POSITIONING from .zmsg import Bcast, Resp, topic log = getLogger("gps303/lookaside") @@ -22,7 +22,7 @@ def runserver(conf: ConfigParser) -> None: zctx = zmq.Context() # type: ignore zsub = zctx.socket(zmq.SUB) # type: ignore zsub.connect(conf.get("collector", "publishurl")) - zsub.setsockopt(zmq.SUBSCRIBE, topic(WIFI_POSITIONING.PROTO)) + zsub.setsockopt(zmq.SUBSCRIBE, topic(proto_name(WIFI_POSITIONING))) zpush = zctx.socket(zmq.PUSH) # type: ignore zpush.connect(conf.get("collector", "listenurl"))