diff options
| author | malosek <malosek@fastmq.com> | 2009-09-15 09:44:44 +0200 |
|---|---|---|
| committer | malosek <malosek@fastmq.com> | 2009-09-15 09:44:44 +0200 |
| commit | 364281343ce0fd03b25bc6b1b451ee7ba8db436b (patch) | |
| tree | 32cd09900e2ecdc31d6a8f2a47a68fe128980169 /src/app_thread.cpp | |
| parent | bdf22e9c2fe82366283f4edc02fd59c37fdb2c4b (diff) | |
| parent | f7ad4a203ad184d97002111f4ffb8bfe6a8f7c01 (diff) | |
Merge branch 'master' of git@github.com:sustrik/zeromq2
Diffstat (limited to 'src/app_thread.cpp')
| -rw-r--r-- | src/app_thread.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/app_thread.cpp b/src/app_thread.cpp index 517b721..feaa4d6 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, type_); |