30 new zmqpp::actor(std::bind(&
MessageBus::run,
this, std::placeholders::_1));
43 pub_ =
new zmqpp::socket(
ctx_, zmqpp::socket_type::pub);
44 pub_->bind(
"inproc://zmq-bus-pub");
46 pull_ =
new zmqpp::socket(
ctx_, zmqpp::socket_type::pull);
47 pull_->bind(
"inproc://zmq-bus-pull");
49 catch (std::exception &e)
54 pipe->send(zmqpp::signal::ok);
56 zmqpp::reactor reactor;
75 if (sig == zmqpp::signal::stop)