Commit 6b452620 authored by Pieter Hintjens's avatar Pieter Hintjens

Merge pull request #448 from jgm-radez/master

resolve issue 456
parents bb59dc1b 500f6cff
......@@ -95,7 +95,13 @@ int zmq::xsub_t::xsend (msg_t *msg_, int flags_)
// Process the subscription.
if (*data == 1) {
if (subscriptions.add (data + 1, size - 1))
// this used to filter out duplicate subscriptions,
// however this is alread done on the XPUB side and
// doing it here as well breaks ZMQ_XPUB_VERBOSE
// when there are forwarding devices involved
//
//if (subscriptions.add (data + 1, size - 1))
subscriptions.add (data + 1, size - 1);
return dist.send_to_all (msg_, flags_);
}
else {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment