[zeromq-dev] Issue when using pub / sub after any other pair
sustrik at 250bpm.com
Thu May 19 16:16:11 CEST 2011
On 05/19/2011 04:11 PM, Pavel Chlupáček wrote:
// 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.
More information about the zeromq-dev