diff options
| author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-13 14:45:23 +0100 |
|---|---|---|
| committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-13 14:45:23 +0100 |
| commit | fa6bf24d8030b0e54fd25b167064482e4cf08a36 (patch) | |
| tree | 9f8f833da9607c9ba3376b45aa5cfafa4305e59c /src/app_thread.cpp | |
| parent | c43aded531014895973c283fdd82bb2e5e85c789 (diff) | |
XREP & XREQ socket types added; zmq_queue device added
Diffstat (limited to 'src/app_thread.cpp')
| -rw-r--r-- | src/app_thread.cpp | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/app_thread.cpp b/src/app_thread.cpp index a671822..308fc36 100644 --- a/src/app_thread.cpp +++ b/src/app_thread.cpp @@ -45,6 +45,8 @@ #include "sub.hpp" #include "req.hpp" #include "rep.hpp" +#include "xreq.hpp" +#include "xrep.hpp" #include "upstream.hpp" #include "downstream.hpp" @@ -175,6 +177,12 @@ zmq::socket_base_t *zmq::app_thread_t::create_socket (int type_) case ZMQ_REP: s = new rep_t (this); break; + case ZMQ_XREQ: + s = new xreq_t (this); + break; + case ZMQ_XREP: + s = new xrep_t (this); + break; case ZMQ_UPSTREAM: s = new upstream_t (this); break; |