diff --git a/src/cluster/backend/zeromq/ZeroMQ.cc b/src/cluster/backend/zeromq/ZeroMQ.cc index c2c5ac52a9..f8d2fe8aed 100644 --- a/src/cluster/backend/zeromq/ZeroMQ.cc +++ b/src/cluster/backend/zeromq/ZeroMQ.cc @@ -72,10 +72,8 @@ constexpr DebugFlag operator&(uint8_t x, DebugFlag y) { return static_cast es, std::unique_ptr ls, std::unique_ptr ehs) - : ThreadedBackend("ZeroMQ", std::move(es), std::move(ls), std::move(ehs)) { - log_push = zmq::socket_t(ctx, zmq::socket_type::push); - main_inproc = zmq::socket_t(ctx, zmq::socket_type::pair); -} + : ThreadedBackend("ZeroMQ", std::move(es), std::move(ls), std::move(ehs)), + main_inproc(zmq::socket_t(ctx, zmq::socket_type::pair)) {} ZeroMQBackend::~ZeroMQBackend() { try { @@ -163,6 +161,7 @@ void ZeroMQBackend::DoTerminate() { bool ZeroMQBackend::DoInit() { xsub = zmq::socket_t(ctx, zmq::socket_type::xsub); xpub = zmq::socket_t(ctx, zmq::socket_type::xpub); + log_push = zmq::socket_t(ctx, zmq::socket_type::push); log_pull = zmq::socket_t(ctx, zmq::socket_type::pull); child_inproc = zmq::socket_t(ctx, zmq::socket_type::pair);