[zeromq-dev] HWM in 2.1
Koert Kuipers
Koert.Kuipers at diamondnotch.com
Sun Jan 9 23:23:55 CET 2011
I do not see same behavior in Java. Does it have something to do with python bindings for 2.1.0 (pyzmq-2.1.0dev)?
********** Test.java **********
import org.zeromq.ZMQ;
public class Test {
public static void main(String[] args) {
final ZMQ.Context context = ZMQ.context(1);
final ZMQ.Socket socket = context.socket(ZMQ.PUSH);
socket.setHWM(100);
socket.connect("tcp://localhost:5051");
for (int i=0; i <1000; i++) {
socket.send(new byte[0], 0);
System.out.println(i);
}
}
}
From: zeromq-dev-bounces at lists.zeromq.org [mailto:zeromq-dev-bounces at lists.zeromq.org] On Behalf Of Koert Kuipers
Sent: Sunday, January 09, 2011 4:50 PM
To: ZeroMQ development list
Subject: [zeromq-dev] HWM in 2.1
The little python program below connects to a socket where nobody is listening. With zmq 2.0.10 it would halt after 100 messages. However with zmq 2.1.0 it keeps going all the way to 1000 messages. Why is this? I see this behavior both under Linux and Windows.
Koert
********** test.py **********
import zmq
context = zmq.Context()
socket = context.socket(zmq.PUSH)
socket.setsockopt(zmq.HWM, 100)
socket.connect("tcp://localhost:5051")
for i in range(1, 1000):
socket.send('')
print i
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20110109/5a498372/attachment.htm>
More information about the zeromq-dev
mailing list