diff options
Diffstat (limited to 'src/zmq_listener.cpp')
| -rw-r--r-- | src/zmq_listener.cpp | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/src/zmq_listener.cpp b/src/zmq_listener.cpp index 1f1e012..9787f7e 100644 --- a/src/zmq_listener.cpp +++ b/src/zmq_listener.cpp @@ -18,9 +18,11 @@ */ #include "zmq_listener.hpp" +#include "zmq_engine.hpp" +#include "io_thread.hpp" #include "err.hpp" -zmq::zmq_listener_t::zmq_listener_t (object_t *parent_, object_t *owner_) : +zmq::zmq_listener_t::zmq_listener_t (io_thread_t *parent_, object_t *owner_) : io_object_t (parent_, owner_) { } @@ -31,5 +33,8 @@ zmq::zmq_listener_t::~zmq_listener_t () void zmq::zmq_listener_t::process_plug () { - // TODO: Register with the I/O thread here. + // TODO: Testing code follows... + object_t *engine = new zmq_engine_t (choose_io_thread (0), owner); + send_plug (engine); + send_own (owner, engine); } |