diff options
Diffstat (limited to 'cpp/src/qpid/broker/ExchangeRegistry.cpp')
-rw-r--r-- | cpp/src/qpid/broker/ExchangeRegistry.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/cpp/src/qpid/broker/ExchangeRegistry.cpp b/cpp/src/qpid/broker/ExchangeRegistry.cpp index 2f58e23c23..58d9d5efb8 100644 --- a/cpp/src/qpid/broker/ExchangeRegistry.cpp +++ b/cpp/src/qpid/broker/ExchangeRegistry.cpp @@ -46,15 +46,15 @@ pair<Exchange::shared_ptr, bool> ExchangeRegistry::declare(const string& name, c Exchange::shared_ptr exchange; if(type == TopicExchange::typeName){ - exchange = Exchange::shared_ptr(new TopicExchange(name, durable, args)); + exchange = Exchange::shared_ptr(new TopicExchange(name, durable, args, parent)); }else if(type == DirectExchange::typeName){ - exchange = Exchange::shared_ptr(new DirectExchange(name, durable, args)); + exchange = Exchange::shared_ptr(new DirectExchange(name, durable, args, parent)); }else if(type == FanOutExchange::typeName){ - exchange = Exchange::shared_ptr(new FanOutExchange(name, durable, args)); + exchange = Exchange::shared_ptr(new FanOutExchange(name, durable, args, parent)); }else if (type == HeadersExchange::typeName) { - exchange = Exchange::shared_ptr(new HeadersExchange(name, durable, args)); + exchange = Exchange::shared_ptr(new HeadersExchange(name, durable, args, parent)); }else if (type == ManagementExchange::typeName) { - exchange = Exchange::shared_ptr(new ManagementExchange(name, durable, args)); + exchange = Exchange::shared_ptr(new ManagementExchange(name, durable, args, parent)); }else{ throw UnknownExchangeTypeException(); } |