diff options
-rw-r--r-- | src/xsub.cpp | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/xsub.cpp b/src/xsub.cpp index aae2654..454dfb0 100644 --- a/src/xsub.cpp +++ b/src/xsub.cpp @@ -30,6 +30,11 @@ zmq::xsub_t::xsub_t (class ctx_t *parent_, uint32_t tid_) : more (false) { options.type = ZMQ_XSUB; + + // When socket is being closed down we don't want to wait till pending + // subscription commands are sent to the wire. + options.linger = 0; + int rc = message.init (); errno_assert (rc == 0); } |