mirror of
https://github.com/zeromq/libzmq.git
synced 2025-03-17 16:43:58 +00:00
Issue 468
XPUB "verbose" mode excludes unsubscriptions
This commit is contained in:
parent
c05a1b1f26
commit
a7438de239
@ -70,8 +70,8 @@ void zmq::xpub_t::xread_activated (pipe_t *pipe_)
|
|||||||
unique = subscriptions.add (data + 1, size - 1, pipe_);
|
unique = subscriptions.add (data + 1, size - 1, pipe_);
|
||||||
|
|
||||||
// If the subscription is not a duplicate store it so that it can be
|
// If the subscription is not a duplicate store it so that it can be
|
||||||
// passed to used on next recv call.
|
// passed to used on next recv call. (Unsubscribe is not verbose.)
|
||||||
if (options.type == ZMQ_XPUB && (unique || verbose))
|
if (options.type == ZMQ_XPUB && (unique || (*data && verbose)))
|
||||||
pending.push_back (blob_t (data, size));
|
pending.push_back (blob_t (data, size));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user