diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2012-10-18 13:37:42 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2012-10-18 13:37:42 +0000 |
| commit | 172d9b2a16cfb817bbe632d050acba7e31401cd2 (patch) | |
| tree | 7c5dd5ccba8734a455f20bccaae1cb80a5483b91 /cpp/src/qpid/broker/HeadersExchange.cpp | |
| parent | c095a631dcb2c7be5e167ed50f658f7c24330a45 (diff) | |
| download | qpid-python-172d9b2a16cfb817bbe632d050acba7e31401cd2.tar.gz | |
WIP - async store interface working for configuration (adding and removing queues, links and exchanges) and for enqueues and dequeues of messages. Transactions are not yet included, and hence some tests will fail.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1399662 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/HeadersExchange.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/HeadersExchange.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/HeadersExchange.cpp b/cpp/src/qpid/broker/HeadersExchange.cpp index ec19765387..76ffa7a922 100644 --- a/cpp/src/qpid/broker/HeadersExchange.cpp +++ b/cpp/src/qpid/broker/HeadersExchange.cpp @@ -167,7 +167,7 @@ HeadersExchange::HeadersExchange(const std::string& _name, bool _durable, mgmtExchange->set_type (typeName); } -bool HeadersExchange::bind(Queue::shared_ptr queue, const string& bindingKey, const FieldTable* args) +bool HeadersExchange::bind(Queue::shared_ptr queue, const string& bindingKey, const FieldTable* args, AsyncStore* const store) { string fedOp(fedOpBind); string fedTags; @@ -221,7 +221,7 @@ bool HeadersExchange::bind(Queue::shared_ptr queue, const string& bindingKey, co bindings.modify_if(MatchKey(queue, bindingKey), modifier); propagate = modifier.shouldPropagate; if (modifier.shouldUnbind) { - unbind(queue, bindingKey, args); + unbind(queue, bindingKey, args, store); } } else if (fedOp == fedOpReorigin) { @@ -246,7 +246,7 @@ bool HeadersExchange::bind(Queue::shared_ptr queue, const string& bindingKey, co return true; } -bool HeadersExchange::unbind(Queue::shared_ptr queue, const string& bindingKey, const FieldTable *args){ +bool HeadersExchange::unbind(Queue::shared_ptr queue, const string& bindingKey, const FieldTable *args, AsyncStore* const /*store*/){ bool propagate = false; string fedOrigin(args ? args->getAsString(qpidFedOrigin) : ""); { |