[zeromq-dev] Router/Dealer lost messages (libzmq 3.1.1)

[Michael Compton]

Are you trying this against libzmq 3.1.1.

I tried this numerous times and it never worked, yet worked first time
with 2.1.11, per my follow up email

On Tue, 24 Jan 2012 12:04:14 +1100
john skaller <skaller at users.sourceforge.net> wrote:

> 
> On 24/01/2012, at 9:08 AM, Michael Compton wrote:
> 
> > Hi,
> > 
> > I am trying to do explicit message routing using Router/Dealer
> > connection pattern, as documented in the zguide:
> > http://zguide.zeromq.org/page:all#toc49 
> > 
> > But the messages never arrive at the destination.
> > 
> > Please find the code here:
> > http://paste.lisp.org/display/127256#1
> > Program output here:
> > http://paste.lisp.org/display/127256#2
 
> 
> 
> This is a synchronisation problem.
> 
> This Felix code works fine:
> 
> ///////////
> open ZMQ;
> 
>   println ("Starting..."); fflush (stdout);
>   var context = zmq_init (1);
>   
>   var dealer = zmq_socket (context, ZMQ_DEALER); 
>   dealer . set_opt$ zmq_identity "A";
>   dealer.connect "tcp://localhost:5555";
> 
>   var router = zmq_socket (context, ZMQ_ROUTER); 
>   router.bind "tcp://*:5555";
> 
>   Faio::sleep(sys_clock,1.0);
>   
>   println ("Sending Payload"); fflush (stdout);
>   dealer.send_string "PAYLOAD";
> 
>   println ("Waiting for payload"); fflush (stdout);
>   var s1 = recv_string router;
>   var s2 = recv_string router;
> 
>   println ("Payload recved '"+s1+"': '"+s2+"'"); fflush (stdout);
> 
> // send back to router
> 
>   router.send_string_part s1;
>   router.send_string s2;
> 
> // fetch from dealer
>   var s3 = recv_string dealer;
>   println ("Payload returned '"+s3); fflush (stdout);
> 
>   close (dealer);
>   close (router);
>   term (context);
> ////
> Starting...
> Sending Payload
> Waiting for payload
> Payload recved 'A': 'PAYLOAD'
> Payload returned 'PAYLOAD
> ////
> 
> The second part of this code is the same as yours. But if you remove
> the first step it hangs:
> 
> /////
> open ZMQ;
> 
>   println ("Starting..."); fflush (stdout);
>   var context = zmq_init (1);
>   
>   var dealer = zmq_socket (context, ZMQ_DEALER); 
>   dealer . set_opt$ zmq_identity "A";
>   dealer.connect "tcp://localhost:5555";
> 
>   var router = zmq_socket (context, ZMQ_ROUTER); 
>   router.bind "tcp://*:5555";
> 
>   Faio::sleep(sys_clock,1.0);
>   
> /*
>   println ("Sending Payload"); fflush (stdout);
>   dealer.send_string "PAYLOAD";
> 
>   println ("Waiting for payload"); fflush (stdout);
>   var s1 = recv_string router;
>   var s2 = recv_string router;
> 
>   println ("Payload recved '"+s1+"': '"+s2+"'"); fflush (stdout);
> 
> // send back to router
> */
> var s1 = "A";
> var s2 = "PAYLOAD";
> 
>   router.send_string_part s1;
>   router.send_string s2;
> 
> // fetch from dealer
>   var s3 = recv_string dealer;
>   println ("Payload returned '"+s3); fflush (stdout);
> 
>   close (dealer);
>   close (router);
>   term (context);
> 
> ////
> 
> Looks like you have to send something to the router first to wake it
> up :) Or maybe the dealer is asleep until you kick it ..
> 
> --
> john skaller
> skaller at users.sourceforge.net
> 
> 
> 
> 
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev