- if not os.path.exists(uwscfg.tracker_socket):
- logging.debug("Socketfile '%s' not found, waiting 5 secs" % uwscfg.tracker_socket)
- time.sleep(5)
- continue
- sockhandle = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
- sockhandle.connect(uwscfg.tracker_socket)
- conn = os.fdopen(sockhandle.fileno())
- #sockhandle.send("listen\n")
- #sockhandle.send("status\n")
+ #Start zmq connection to publish / forward sensor data
+ zmqctx = zmq.Context()
+ zmqctx.linger = 0
+ zmqsub = zmqctx.socket(zmq.SUB)
+ zmqsub.setsockopt(zmq.SUBSCRIBE, "DoorCommandEvent")
+ zmqsub.setsockopt(zmq.SUBSCRIBE, "PresenceUpdate")
+ zmqsub.setsockopt(zmq.SUBSCRIBE, "BoreDoomButtonPressEvent")
+# zmqsub.setsockopt(zmq.SUBSCRIBE, "MovementSensorUpdate")
+ zmqsub.setsockopt(zmq.SUBSCRIBE, "DoorAjarUpdate")
+ zmqsub.setsockopt(zmq.SUBSCRIBE, "DoorProblemEvent")
+ zmqsub.connect(uwscfg.broker_uri)
+