There is a bug when using the edge-triggered fd from a zmq socket. I am not sure if it's fixed upstream yet or not. See here for an ugly workaround: https://github.com/dotcloud/zerorpc-python/blob/master/zeror...
Also, this looks to be a fix in recv(), I am having issues in send() hanging randomly blocking the entire process. I ended up using a with timeout block around it so if send blocked it would eventually get back to me...
sent = "WAITING"
with gevent.Timeout(0.5, False):
sent = self.socket.send_multipart(tosend)
if sent is "WAITING":
print "__incoming_consumer: Timeout fired"
# We are going to try again
with gevent.Timeout(2, False):
sent = self.socket.send_multipart(tosend)
if sent is "WAITING":
print "__incoming_consumer: Timeout 2 fired"
continue
gevent.hub.sleep(0) # Yield to other gevent's, we can be fast and never let up ...