Commit ec61751e authored by Martin Sustrik's avatar Martin Sustrik

options.type correctly set for PUB/SUB/XPUB/XSUB

Signed-off-by: 's avatarMartin Sustrik <sustrik@250bpm.com>
parent 8a6ff4cc
......@@ -22,6 +22,7 @@
zmq::pub_t::pub_t (class ctx_t *parent_, uint32_t tid_) :
xpub_t (parent_, tid_)
{
options.type = ZMQ_PUB;
}
zmq::pub_t::~pub_t ()
......
......@@ -24,6 +24,7 @@
zmq::sub_t::sub_t (class ctx_t *parent_, uint32_t tid_) :
xsub_t (parent_, tid_)
{
options.type = ZMQ_SUB;
}
zmq::sub_t::~sub_t ()
......
......@@ -29,7 +29,7 @@ zmq::xpub_t::xpub_t (class ctx_t *parent_, uint32_t tid_) :
active (0),
terminating (false)
{
options.type = ZMQ_PUB;
options.type = ZMQ_XPUB;
options.requires_in = false;
options.requires_out = true;
}
......
......@@ -30,7 +30,7 @@ zmq::xsub_t::xsub_t (class ctx_t *parent_, uint32_t tid_) :
has_message (false),
more (false)
{
options.type = ZMQ_SUB;
options.type = ZMQ_XSUB;
options.requires_in = true;
options.requires_out = false;
zmq_msg_init (&message);
......
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