1 """ Watch for locevt and print them """
3 from datetime import datetime, timezone
4 from logging import getLogger
8 from .zmsg import Bcast
10 log = getLogger("gps303/watch")
15 zsub = zctx.socket(zmq.SUB)
16 zsub.connect(conf.get("collector", "publishurl"))
17 zsub.setsockopt(zmq.SUBSCRIBE, b"")
21 zmsg = Bcast(zsub.recv())
22 msg = parse_message(zmsg.packet)
24 except KeyboardInterrupt:
28 if __name__.endswith("__main__"):
29 runserver(common.init(log))