Attachment 834835 Details for Bug 916975 – Patch proposal

[patch] Patch proposal

bz916975.patch (text/plain), 1.03 KB, created by Pavel Moravec on 2013-12-10 15:21:51 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Pavel Moravec

Created: 2013-12-10 15:21:51 UTC

Size: 1.03 KB

patch

obsolete

>Index: ../src/qpid/broker/HeadersExchange.cpp
>===================================================================
>--- ../src/qpid/broker/HeadersExchange.cpp	(revision 1543447)
>+++ ../src/qpid/broker/HeadersExchange.cpp	(working copy)
>@@ -298,14 +298,17 @@
>     PreRoute pr(msg, this);
> 
>     BindingList b(new std::vector<boost::shared_ptr<qpid::broker::Exchange::Binding> >);
>+    std::map<std::string,boost::shared_ptr<qpid::broker::Exchange::Binding> > uniqueQueueMatch;
>     Bindings::ConstPtr p = bindings.snapshot();
>     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);
>+		uniqueQueueMatch[(*i).binding->queue->getName()]=(*i).binding;
>             }
>         }
>     }
>+    for (std::map<std::string,boost::shared_ptr<qpid::broker::Exchange::Binding> >::const_iterator i = uniqueQueueMatch.begin(); i != uniqueQueueMatch.end(); ++i)
>+        b->push_back(i->second);
>     doRoute(msg, b);
> }
>

Actions: View | Diff

Attachments on bug 916975: 834835