On Wednesday, March 20, 2013 12:14:09 PM He Jie Xu wrote:
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
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, 10)
temperature = random.randrange(1, 215)
Hi,
The HWM is a maximum buffer length (not actually identical).
For PUSH, send will block if it reach the HWM.
Thanks
Min
On Wednesday, March 20, 2013, He Jie Xu wrote:
Hi, all
I try zeromq with following code:
import zmq
import random
import time
context = zmq.Context()
socket =