From cf14c5410208f5d6f9e69c223d981dfba2e206c7 Mon Sep 17 00:00:00 2001 From: Martin Hurton Date: Sat, 30 Nov 2013 21:24:32 +0100 Subject: [PATCH] Fix issue #763 --- src/stream_engine.cpp | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/stream_engine.cpp b/src/stream_engine.cpp index 68780d28..cb70680b 100644 --- a/src/stream_engine.cpp +++ b/src/stream_engine.cpp @@ -507,6 +507,13 @@ bool zmq::stream_engine_t::handshake () // message into the incoming message stream. if (options.type == ZMQ_PUB || options.type == ZMQ_XPUB) subscription_required = true; + + // We are sending our identity now and the next message + // will come from the socket. + read_msg = &stream_engine_t::pull_msg_from_session; + + // We are expecting identity message. + write_msg = &stream_engine_t::write_identity; } else if (greeting_recv [revision_pos] == ZMTP_1_0) {