diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2011-06-11 20:29:56 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2011-06-11 20:29:56 +0200 |
commit | bd86def1c799a35d5cef0c0a9a1347a18fea227e (patch) | |
tree | 4d70d0053ef86b5a614bd19ad4c5f420017279c7 /src/xsub.cpp | |
parent | 3935258b826adc31815be4f91b2f6eb02bb3c8ed (diff) |
Actual message filtering happens in XPUB socket
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/xsub.cpp')
-rw-r--r-- | src/xsub.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/xsub.cpp b/src/xsub.cpp index 729f6a4..a847d7f 100644 --- a/src/xsub.cpp +++ b/src/xsub.cpp @@ -87,13 +87,13 @@ int zmq::xsub_t::xsend (msg_t *msg_, int flags_) // Process the subscription. if (*data == 1) { if (subscriptions.add (data + 1, size - 1)) - return dist.send (msg_, flags_); + return dist.send_to_all (msg_, flags_); else return 0; } else if (*data == 0) { if (subscriptions.rm (data + 1, size - 1)) - return dist.send (msg_, flags_); + return dist.send_to_all (msg_, flags_); else return 0; } |