From: Bernhard Tittelbach Date: Wed, 16 Oct 2013 17:19:09 +0000 (+0000) Subject: .. X-Git-Url: https://git.realraum.at/?a=commitdiff_plain;h=271a99d6799d9da0cc567f03148ff1d71974e77c;p=svn42.git .. --- diff --git a/bridge-old-sensors-zmq.py b/bridge-old-sensors-zmq.py index 65e5bc9..459d854 100755 --- a/bridge-old-sensors-zmq.py +++ b/bridge-old-sensors-zmq.py @@ -222,7 +222,7 @@ def exitHandler(signum, frame): pass time.sleep(0.1) try: - zmqsub.close() + zmqpub.close() zmqctx.destroy() except: pass @@ -250,7 +250,7 @@ zmqpub.connect("tcp://wuzzler.realraum.at:4243") #listen for sensor data and forward them trackSensorStatus(uwscfg, zmqpub) -zmqsub.close() +zmqpub.close() zmqctx.destroy() diff --git a/inject_presence.py b/inject_presence.py new file mode 100755 index 0000000..731469f --- /dev/null +++ b/inject_presence.py @@ -0,0 +1,25 @@ +#!/usr/bin/python +# -*- coding: utf-8 -*- +from __future__ import with_statement +import zmq.utils.jsonapi as json +import zmq +import time + +######## r3 ZMQ ############ + +def sendR3Message(socket, structname, datadict): + socket.send_multipart([structname, json.dumps(datadict)]) + +#Start zmq connection to publish / forward sensor data +zmqctx = zmq.Context() +zmqctx.linger = 0 +zmqpub = zmqctx.socket(zmq.PUB) +zmqpub.connect("tcp://wuzzler.realraum.at:4243") + +#listen for sensor data and forward them +sendR3Message(zmqpub,"PresenceUpdate",{"Presence":True,"Ts":int(time.time())}) + +zmqpub.close() +zmqctx.destroy() + +