From 5b5b513330e96e3e08d0c2c60d03044091976420 Mon Sep 17 00:00:00 2001
From: Martin Sustrik <sustrik@fastmq.commkdir>
Date: Sun, 9 Aug 2009 09:24:48 +0200
Subject: socket options interface modeled as in BSD sockets

---
 src/zmq_listener.cpp | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

(limited to 'src/zmq_listener.cpp')

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);
 }
-- 
cgit v1.2.3