have to se a subscription filter on the publish socket - this thing is

cool I will have to use it to speed things up in the long run
This commit is contained in:
Thomas S Hatch 2011-03-07 22:08:31 -07:00
parent fff3e2ed2e
commit 12c08a782a

View file

@ -90,6 +90,7 @@ class Minion(object):
context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect(master_pub)
socket.setsockopt(zmq.SUBSCRIBE, '')
while True:
payload = socket.recv()
self._handle_payload(payload)