summaryrefslogtreecommitdiff
path: root/src/zmq_connecter_init.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-09-11 13:20:24 +0200
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-09-11 13:20:24 +0200
commit5daa0dec0f473c84aab6b12cdc5541335e74f07f (patch)
treec7a7b5845cd1fa94a25850af1d5d252976c442c5 /src/zmq_connecter_init.cpp
parentf824b8a067c60b32260c56020742d6428ed3bb98 (diff)
ZMQII-5: Only one consumer in a process gets the message
Diffstat (limited to 'src/zmq_connecter_init.cpp')
-rw-r--r--src/zmq_connecter_init.cpp4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/zmq_connecter_init.cpp b/src/zmq_connecter_init.cpp
index 4e996d8..730077a 100644
--- a/src/zmq_connecter_init.cpp
+++ b/src/zmq_connecter_init.cpp
@@ -55,7 +55,9 @@ bool zmq::zmq_connecter_init_t::read (::zmq_msg_t *msg_)
// Find the session associated with this connecter. If it doesn't exist
// drop the newly created connection. If it does, attach it to the
// connection.
- session_t *session = owner->find_session (session_name.c_str ());
+ session_t *session = NULL;
+ if (!session_name.empty ())
+ session = owner->find_session (session_name.c_str ());
if (!session) {
// TODO
zmq_assert (false);