socket options interface modeled as in BSD sockets

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);
 }