summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/xsub.cpp5
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);
}