diff options
Diffstat (limited to 'cpp/src')
-rw-r--r-- | cpp/src/qpid/broker/DeliveryRecord.cpp | 2 | ||||
-rw-r--r-- | cpp/src/qpid/broker/Exchange.cpp | 9 | ||||
-rw-r--r-- | cpp/src/qpid/broker/Exchange.h | 2 | ||||
-rw-r--r-- | cpp/src/qpid/broker/Queue.cpp | 3 |
4 files changed, 13 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/DeliveryRecord.cpp b/cpp/src/qpid/broker/DeliveryRecord.cpp index 64760bea36..58dcc6d7c7 100644 --- a/cpp/src/qpid/broker/DeliveryRecord.cpp +++ b/cpp/src/qpid/broker/DeliveryRecord.cpp @@ -135,7 +135,7 @@ void DeliveryRecord::reject() Exchange::shared_ptr alternate = queue->getAlternateExchange(); if (alternate) { DeliverableMessage delivery(msg.payload); - alternate->route(delivery, msg.payload->getRoutingKey(), msg.payload->getApplicationHeaders()); + alternate->routeWithAlternate(delivery); QPID_LOG(info, "Routed rejected message from " << queue->getName() << " to " << alternate->getName()); } else { diff --git a/cpp/src/qpid/broker/Exchange.cpp b/cpp/src/qpid/broker/Exchange.cpp index d143471559..2c7589e4b6 100644 --- a/cpp/src/qpid/broker/Exchange.cpp +++ b/cpp/src/qpid/broker/Exchange.cpp @@ -342,3 +342,12 @@ bool Exchange::MatchQueue::operator()(Exchange::Binding::shared_ptr b) void Exchange::setProperties(const boost::intrusive_ptr<Message>& msg) { msg->getProperties<DeliveryProperties>()->setExchange(getName()); } + +bool Exchange::routeWithAlternate(Deliverable& msg) +{ + route(msg, msg.getMessage().getRoutingKey(), msg.getMessage().getApplicationHeaders()); + if (!msg.delivered && alternate) { + alternate->route(msg, msg.getMessage().getRoutingKey(), msg.getMessage().getApplicationHeaders()); + } + return msg.delivered; +} diff --git a/cpp/src/qpid/broker/Exchange.h b/cpp/src/qpid/broker/Exchange.h index 3c8b5ca2cd..9c4e6be192 100644 --- a/cpp/src/qpid/broker/Exchange.h +++ b/cpp/src/qpid/broker/Exchange.h @@ -222,6 +222,8 @@ public: */ void recoveryComplete(ExchangeRegistry& exchanges); + bool routeWithAlternate(Deliverable& message); + protected: qpid::sys::Mutex bridgeLock; std::vector<DynamicBridge*> bridgeVector; diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp index edae8dc24f..29b3c0d585 100644 --- a/cpp/src/qpid/broker/Queue.cpp +++ b/cpp/src/qpid/broker/Queue.cpp @@ -834,8 +834,7 @@ void Queue::destroyed() Mutex::ScopedLock locker(messageLock); while(!messages->empty()){ DeliverableMessage msg(messages->front().payload); - alternateExchange->route(msg, msg.getMessage().getRoutingKey(), - msg.getMessage().getApplicationHeaders()); + alternateExchange->routeWithAlternate(msg); popAndDequeue(); } alternateExchange->decAlternateUsers(); |