Skip to content

L
libzmq
Commit b8d5d3fa authored by John Muehlhausen's avatar John Muehlhausen
Browse files
Options

Issue 468 

XPUB "verbose" mode excludes unsubscriptions
parent 01b9bc36
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
src/xpub.cpp
View file @ b8d5d3fa
...@@ -70,8 +70,8 @@ void zmq::xpub_t::xread_activated (pipe_t *pipe_) ...@@ -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));
} }
......
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