diff options
Diffstat (limited to 'cpp')
| -rw-r--r-- | cpp/src/qpid/xml/XmlExchange.cpp | 5 | ||||
| -rw-r--r-- | cpp/src/qpid/xml/XmlExchange.h | 7 |
2 files changed, 8 insertions, 4 deletions
diff --git a/cpp/src/qpid/xml/XmlExchange.cpp b/cpp/src/qpid/xml/XmlExchange.cpp index 472ca28954..6771767969 100644 --- a/cpp/src/qpid/xml/XmlExchange.cpp +++ b/cpp/src/qpid/xml/XmlExchange.cpp @@ -82,8 +82,8 @@ bool XmlExchange::bind(Queue::shared_ptr queue, const string& routingKey, const XmlBinding::vector::ConstPtr p = bindings.snapshot(); if (!p || std::find_if(p->begin(), p->end(), MatchQueue(queue)) == p->end()) { Query query(xqilla.parse(X(queryText.c_str()))); - XmlBinding::shared_ptr binding(new XmlBinding (routingKey, queue, this, query)); - bindings.add(binding); + XmlBinding::shared_ptr binding(new XmlBinding (routingKey, queue, this, *bindingArguments, query)); + QPID_LOG(trace, "Bound successfully with query: " << queryText ); binding->parse_message_content = false; @@ -101,6 +101,7 @@ bool XmlExchange::bind(Queue::shared_ptr queue, const string& routingKey, const } } + bindings.add(binding); if (mgmtExchange != 0) { mgmtExchange->inc_bindingCount(); ((_qmf::Queue*) queue->GetManagementObject())->inc_bindingCount(); diff --git a/cpp/src/qpid/xml/XmlExchange.h b/cpp/src/qpid/xml/XmlExchange.h index 38cb7699b6..802afddeab 100644 --- a/cpp/src/qpid/xml/XmlExchange.h +++ b/cpp/src/qpid/xml/XmlExchange.h @@ -49,8 +49,11 @@ class XmlExchange : public virtual Exchange { boost::shared_ptr<XQQuery> xquery; bool parse_message_content; - XmlBinding(const std::string& key, const Queue::shared_ptr queue, Exchange* parent, Query query): - Binding(key, queue, parent), xquery(query), parse_message_content(true) {} + XmlBinding(const std::string& key, const Queue::shared_ptr queue, Exchange* parent, + const ::qpid::framing::FieldTable& _arguments, Query query): + Binding(key, queue, parent, _arguments), + xquery(query), + parse_message_content(true) {} }; |