From caca23c5dc055d985fecfe188573104bc707ad9d Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 27 Sep 2006 19:50:23 +0000 Subject: git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@450556 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/broker/src/SessionHandlerFactoryImpl.cpp | 3 +++ 1 file changed, 3 insertions(+) (limited to 'cpp/broker/src/SessionHandlerFactoryImpl.cpp') diff --git a/cpp/broker/src/SessionHandlerFactoryImpl.cpp b/cpp/broker/src/SessionHandlerFactoryImpl.cpp index 280e89c475..39c627afef 100644 --- a/cpp/broker/src/SessionHandlerFactoryImpl.cpp +++ b/cpp/broker/src/SessionHandlerFactoryImpl.cpp @@ -18,6 +18,7 @@ #include "SessionHandlerFactoryImpl.h" #include "SessionHandlerImpl.h" #include "FanOutExchange.h" +#include "HeadersExchange.h" using namespace qpid::broker; using namespace qpid::io; @@ -28,6 +29,7 @@ const std::string empty; const std::string amq_direct("amq.direct"); const std::string amq_topic("amq.topic"); const std::string amq_fanout("amq.fanout"); +const std::string amq_match("amq.match"); } SessionHandlerFactoryImpl::SessionHandlerFactoryImpl(u_int32_t _timeout) : timeout(_timeout), cleaner(&queues, timeout/10){ @@ -35,6 +37,7 @@ SessionHandlerFactoryImpl::SessionHandlerFactoryImpl(u_int32_t _timeout) : timeo exchanges.declare(new DirectExchange(amq_direct)); exchanges.declare(new TopicExchange(amq_topic)); exchanges.declare(new FanOutExchange(amq_fanout)); + exchanges.declare(new HeadersExchange(amq_match)); cleaner.start(); } -- cgit v1.2.1