diff options
Diffstat (limited to 'gr-zeromq/lib/sub_msg_source_impl.cc')
| -rw-r--r-- | gr-zeromq/lib/sub_msg_source_impl.cc | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/gr-zeromq/lib/sub_msg_source_impl.cc b/gr-zeromq/lib/sub_msg_source_impl.cc index 4a44442e62..8ed2420293 100644 --- a/gr-zeromq/lib/sub_msg_source_impl.cc +++ b/gr-zeromq/lib/sub_msg_source_impl.cc @@ -44,7 +44,8 @@ namespace gr { : gr::block("sub_msg_source", gr::io_signature::make(0, 0, 0), gr::io_signature::make(0, 0, 0)), - d_timeout(timeout) + d_timeout(timeout), + d_port(pmt::mp("out")) { int major, minor, patch; zmq::version(&major, &minor, &patch); @@ -59,7 +60,7 @@ namespace gr { d_socket->setsockopt(ZMQ_SUBSCRIBE, "", 0); d_socket->connect (address); - message_port_register_out(pmt::mp("out")); + message_port_register_out(d_port); } sub_msg_source_impl::~sub_msg_source_impl() @@ -101,7 +102,7 @@ namespace gr { std::stringbuf sb(buf); pmt::pmt_t m = pmt::deserialize(sb); - message_port_pub(pmt::mp("out"), m); + message_port_pub(d_port, m); } else { boost::this_thread::sleep(boost::posix_time::microseconds(100)); } |