Sorry, wrong answer.
2013/5/23 Apostolis Xekoukoulotakis <[email protected]> > You are probably disconnecting push before it is able to send the msgs. > > > 2013/5/23 Trevor Bernard <[email protected]> > >> I'm using libzmq 3.2.3 >> >> >> >> On Wed, May 22, 2013 at 12:05 PM, Trevor Bernard < >> [email protected]> wrote: >> >>> What should the functionality be for the following scenario? >>> >>> ;; Conceptually, assume push and pull sockets are different processes >>> (def ctx (zcontext 1)) >>> (def ctx2 (zcontext 2)) >>> >>> (def push (-> (socket ctx :push) >>> (connect "tcp://localhost:12345"))) >>> (send push (.getBytes "msg1")) ;; true >>> (send push (.getBytes "msg2")) ;; true >>> >>> >>> (def pull (-> (socket ctx2 :pull) >>> (bind "tcp://*:12345"))) >>> >>> ;; receive queued messages as expected >>> (String. (recv pull)) "msg1" >>> (String. (recv pull)) "msg2" >>> (close pull) ;; simulate loss of connection >>> >>> (send push (.getBytes "msg3")) >>> (send push (.getBytes "msg4")) >>> (send push (.getBytes "msg5")) >>> >>> (def pull2 (-> (socket ctx2 :pull) >>> (bind "tcp://*:12345"))) >>> >>> ;; Again, received queued messages >>> (String. (recv pull2)) ;; "msg3" >>> (String. (recv pull2)) ;; "msg4" >>> (String. (recv pull2)) ;; "msg5" >>> (close pull2) >>> >>> (send push (.getBytes "msg6")) ;; true >>> (send push (.getBytes "msg7")) ;; true >>> (send push (.getBytes "msg8")) ;; true >>> >>> ;; Simulate failover to a new endpoint >>> (disconnect push "tcp://localhost:12345") >>> (connect push "tcp://localhost:1337") >>> >>> (send push (.getBytes "msg9")) ;; true >>> (def pull3 (-> (socket ctx2 :pull) >>> (bind "tcp://*:1337"))) >>> >>> ;; Expected to receive msg6-9 >>> (String. (recv pull3)) ;; "msg9" >>> >>> I expected the messages to be queued up and to receive msg6..9 but only >>> received msg9. Are messages 6-8 lost? >>> >>> -Trev >>> >> >> >> _______________________________________________ >> zeromq-dev mailing list >> [email protected] >> http://lists.zeromq.org/mailman/listinfo/zeromq-dev >> >> > > > -- > > > Sincerely yours, > > Apostolis Xekoukoulotakis > > -- Sincerely yours, Apostolis Xekoukoulotakis
_______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev
