From 47350adcb6ea48512d732bc323eb1835a5ac9908 Mon Sep 17 00:00:00 2001
From: Martin Sustrik <sustrik@fastmq.commkdir>
Date: Fri, 11 Sep 2009 18:16:47 +0200
Subject: separate class for PUB-style socket added

---
 src/app_thread.cpp | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

(limited to 'src/app_thread.cpp')

diff --git a/src/app_thread.cpp b/src/app_thread.cpp
index 2bcc724..c48657a 100644
--- a/src/app_thread.cpp
+++ b/src/app_thread.cpp
@@ -35,6 +35,7 @@
 #include "pipe.hpp"
 #include "config.hpp"
 #include "socket_base.hpp"
+#include "pub.hpp"
 #include "sub.hpp"
 
 //  If the RDTSC is available we use it to prevent excessive
@@ -138,11 +139,13 @@ zmq::socket_base_t *zmq::app_thread_t::create_socket (int type_)
 {
     socket_base_t *s = NULL;
     switch (type_) {
+    case ZMQ_PUB:
+        s = new pub_t (this);
+        break;
     case ZMQ_SUB:
         s = new sub_t (this);
         break;
     case ZMQ_P2P:
-    case ZMQ_PUB:
     case ZMQ_REQ:
     case ZMQ_REP:
         s = new socket_base_t (this);
-- 
cgit v1.2.3