diff options
author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-02 21:26:47 +0100 |
---|---|---|
committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-02 21:26:47 +0100 |
commit | 7146ef85e96551ce6f7b80d014463f246d09c878 (patch) | |
tree | 103ccf90868acc3982987643817f385fbde76681 /src/zmq_listener_init.cpp | |
parent | cb84580bbced0b5d34ddcbac6e0aed5d0ad7cae6 (diff) |
seqnum mechanism automated
Diffstat (limited to 'src/zmq_listener_init.cpp')
-rw-r--r-- | src/zmq_listener_init.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/zmq_listener_init.cpp b/src/zmq_listener_init.cpp index 0d9488d..632bebe 100644 --- a/src/zmq_listener_init.cpp +++ b/src/zmq_listener_init.cpp @@ -83,7 +83,10 @@ void zmq::zmq_listener_init_t::flush () // Reserve a sequence number for following 'attach' command. session->inc_seqnum (); } - send_attach (session, engine); + + // No need to increment seqnum as it was laready incremented above. + send_attach (session, engine, false); + engine = NULL; // Destroy the init object. @@ -103,7 +106,6 @@ void zmq::zmq_listener_init_t::process_plug () { zmq_assert (engine); engine->plug (this); - owned_t::process_plug (); } void zmq::zmq_listener_init_t::process_unplug () |