[zeromq-dev] Issue when using pub / sub after any other pair

[Martin Sustrik]

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