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/SessionHandlerImpl.cpp | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) (limited to 'cpp/broker/src/SessionHandlerImpl.cpp') diff --git a/cpp/broker/src/SessionHandlerImpl.cpp b/cpp/broker/src/SessionHandlerImpl.cpp index 2ce1c4b298..eb8f37030c 100644 --- a/cpp/broker/src/SessionHandlerImpl.cpp +++ b/cpp/broker/src/SessionHandlerImpl.cpp @@ -18,6 +18,8 @@ #include #include "SessionHandlerImpl.h" #include "FanOutExchange.h" +#include "TopicExchange.h" +#include "HeadersExchange.h" #include "assert.h" using namespace std::tr1; @@ -223,7 +225,9 @@ void SessionHandlerImpl::ExchangeHandlerImpl::declare(u_int16_t channel, u_int16 if(!passive && ( type != TopicExchange::typeName && type != DirectExchange::typeName && - type != FanOutExchange::typeName) + type != FanOutExchange::typeName && + type != HeadersExchange::typeName + ) ) { throw ChannelException(540, "Exchange type not implemented: " + type); @@ -237,6 +241,8 @@ void SessionHandlerImpl::ExchangeHandlerImpl::declare(u_int16_t channel, u_int16 parent->exchanges->declare(new DirectExchange(exchange)); }else if(type == FanOutExchange::typeName){ parent->exchanges->declare(new DirectExchange(exchange)); + }else if (type == HeadersExchange::typeName) { + parent->exchanges->declare(new HeadersExchange(exchange)); } } parent->exchanges->getLock()->release(); -- cgit v1.2.1