From fa6bf24d8030b0e54fd25b167064482e4cf08a36 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Sun, 13 Dec 2009 14:45:23 +0100 Subject: XREP & XREQ socket types added; zmq_queue device added --- src/app_thread.cpp | 8 ++++++++ 1 file changed, 8 insertions(+) (limited to 'src/app_thread.cpp') 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; -- cgit v1.2.3