Hi, all
I try zeromq with following code:
import zmq
import random
import time
context = zmq.Context()
socket = context.socket(zmq.PUSH)
socket.bind("ipc://test.sock")
socket.setsockopt(zmq.HWM, 1000)
while True:
zipcode = random.randrange(1, 100000)
temperature = random.randrange(1, 215)
message = "%d %d" % (zipcode, temperature)
socket.send(message)
print 'send', message
time.sleep(1)
When I am running the code without any consumer. it will block at
'socket.send'
But after I read the document, I think when I set HWM, the message will
send to memory buffer, it shouldn't block. Is there any wrong? How can I
make the 'socket.send' won't block?
my zmq version was 2.1.11
I will appreciate any help from you!
Thanks you.
_______________________________________________
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev
