diff options
| author | Gordon Sim <gsim@apache.org> | 2011-06-09 15:35:35 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2011-06-09 15:35:35 +0000 |
| commit | de1653af9bb0405b46d4317bc2e89c8f6c81276a (patch) | |
| tree | 8b8d43f86cdee88255a18e42e23756076481a878 /cpp/src/qpid | |
| parent | c8c7bcaa46eb47a249c6e05546253e462e705cab (diff) | |
| download | qpid-python-de1653af9bb0405b46d4317bc2e89c8f6c81276a.tar.gz | |
QPID-3298: don't include the internal federation related args in the biding for headers exchange
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1133942 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid')
| -rw-r--r-- | cpp/src/qpid/broker/HeadersExchange.cpp | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/HeadersExchange.cpp b/cpp/src/qpid/broker/HeadersExchange.cpp index abcaa5f69d..4bda70d313 100644 --- a/cpp/src/qpid/broker/HeadersExchange.cpp +++ b/cpp/src/qpid/broker/HeadersExchange.cpp @@ -112,9 +112,14 @@ bool HeadersExchange::bind(Queue::shared_ptr queue, const string& bindingKey, co { Mutex::ScopedLock l(lock); - Binding::shared_ptr binding (new Binding (bindingKey, queue, this, *args)); + //NOTE: do not include the fed op/tags/origin in the + //arguments as when x-match is 'all' these would prevent + //matching (they are internally added properties + //controlling binding propagation but not relevant to + //actual routing) + Binding::shared_ptr binding (new Binding (bindingKey, queue, this, extra_args)); BoundKey bk(binding); - if (bindings.add_unless(bk, MatchArgs(queue, args))) { + if (bindings.add_unless(bk, MatchArgs(queue, &extra_args))) { binding->startManagement(); propagate = bk.fedBinding.addOrigin(queue->getName(), fedOrigin); if (mgmtExchange != 0) { |