From bd86def1c799a35d5cef0c0a9a1347a18fea227e Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Sat, 11 Jun 2011 20:29:56 +0200 Subject: Actual message filtering happens in XPUB socket Signed-off-by: Martin Sustrik --- src/xsub.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'src/xsub.cpp') 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; } -- cgit v1.2.3