3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-03-17 08:34:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix issue #763

Browse Source
This commit is contained in:
Martin Hurton 2013-11-30 21:24:32 +01:00 committed by Pieter Hintjens
parent 75ba4c7292
commit ff8f97e7d7
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/stream_engine.cpp
View File

@ -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) {