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:
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()
> s
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