From c3b93ca895efa1175e5891ba73b0407e421ad31e Mon Sep 17 00:00:00 2001
From: Pavel Moravec <pmoravec@apache.org>
Date: Mon, 3 Feb 2014 12:49:01 +0000
Subject: QPID-5534: [C++ broker] Headers exchange can route a message to one
 queue multiple times

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1563863 13f79535-47bb-0310-9956-ffa450edef68
---
 qpid/cpp/src/qpid/broker/HeadersExchange.cpp | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

(limited to 'qpid/cpp/src')

diff --git a/qpid/cpp/src/qpid/broker/HeadersExchange.cpp b/qpid/cpp/src/qpid/broker/HeadersExchange.cpp
index 19c7f107f6..585c7ba764 100644
--- a/qpid/cpp/src/qpid/broker/HeadersExchange.cpp
+++ b/qpid/cpp/src/qpid/broker/HeadersExchange.cpp
@@ -302,7 +302,12 @@ void HeadersExchange::route(Deliverable& msg)
     if (p.get()) {
         for (std::vector<BoundKey>::const_iterator i = p->begin(); i != p->end(); ++i) {
             if (match(i->args, msg.getMessage())) {
-                b->push_back(i->binding);
+                /* check if a binding tothe same queue has not been already added to b */
+                std::vector<boost::shared_ptr<qpid::broker::Exchange::Binding> >::iterator bi = b->begin();
+                while ((bi != b->end()) && ((*bi)->queue != i->binding->queue))
+                    ++bi;
+                if (bi == b->end())
+                    b->push_back(i->binding);
             }
         }
     }
-- 
cgit v1.2.1