Skip to content

Instantly share code, notes, and snippets.

@teepark
Created April 7, 2011 22:07
Show Gist options
  • Save teepark/908864 to your computer and use it in GitHub Desktop.
Save teepark/908864 to your computer and use it in GitHub Desktop.
import select
import zmq
ctx = zmq.Context()
requester = ctx.socket(zmq.REQ)
replyer = ctx.socket(zmq.REP)
replyer.bind("inproc://testology")
requester.connect("inproc://testology")
print "replyer events:", replyer.getsockopt(zmq.EVENTS)
print "sending request"
requester.send("howdy!")
print "replyer polling..."
select.select([replyer.getsockopt(zmq.FD)], [], [], 3)
print "poll returned"
print "replyer events:", replyer.getsockopt(zmq.EVENTS)
replyer.recv()
replyer.send("a response")
requester.recv()
print "\n"
# this time without a getsockopt(EVENTS) beforehand
requester.send("hello again")
print "replyer polling..."
select.select([replyer.getsockopt(zmq.FD)], [], [], 3)
print "poll returned"
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment