On 05/19/2011 04:11 PM, Pavel Chlupáček wrote:
> socketSub.connect("ipc://foo-S")
// Connecting starts at this point. We should expect it to take
// some microseconds.
> val zm = ZMQMessage("Test", serializer).sendTo(socketPub)
// Message is sent immediately. Sub socket is still not connected,
// thus the message is dropped.
> assert(poller.poll(1000)> 0&& poller.pollin(idxSub), "NO message
> in queue? ")
// Poll timeouts.
Martin
_______________________________________________
zeromq-dev mailing list
[email protected]
http://lists.zeromq.org/mailman/listinfo/zeromq-dev
