diff options
author | Alan Conway <aconway@apache.org> | 2006-09-21 18:26:31 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2006-09-21 18:26:31 +0000 |
commit | 474ed3cf1e125360d26dad4376e106e8b48541ac (patch) | |
tree | 4f1043da7f03a5ec230539a62afac3fb0f0f0b73 /cpp/broker/inc/DirectExchange.h | |
parent | 82e07bb30905feb2c11bb6d9f3624f976ab070a5 (diff) | |
download | qpid-python-474ed3cf1e125360d26dad4376e106e8b48541ac.tar.gz |
Implemented topic pattern matching for the TopicExchange.
Corrected default bindings to use the exchange named "" rather than
"amqp.direct".
Added python and unit tests for all of the above.
Minor improvements to testlib.py, also some tests for testlib itself.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@448624 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/broker/inc/DirectExchange.h')
-rw-r--r-- | cpp/broker/inc/DirectExchange.h | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/cpp/broker/inc/DirectExchange.h b/cpp/broker/inc/DirectExchange.h index bf8c5f0b37..faf5a0b949 100644 --- a/cpp/broker/inc/DirectExchange.h +++ b/cpp/broker/inc/DirectExchange.h @@ -29,22 +29,19 @@ namespace qpid { namespace broker { class DirectExchange : public virtual Exchange{ - const string name; std::map<string, std::vector<Queue::shared_ptr> > bindings; qpid::concurrent::MonitorImpl lock; public: static const std::string typeName; - DirectExchange(const string& name); + DirectExchange(const std::string& name); - inline virtual const string& getName(){ return name; } - - virtual void bind(Queue::shared_ptr queue, const string& routingKey, qpid::framing::FieldTable* args); + virtual void bind(Queue::shared_ptr queue, const std::string& routingKey, qpid::framing::FieldTable* args); - virtual void unbind(Queue::shared_ptr queue, const string& routingKey, qpid::framing::FieldTable* args); + virtual void unbind(Queue::shared_ptr queue, const std::string& routingKey, qpid::framing::FieldTable* args); - virtual void route(Message::shared_ptr& msg, const string& routingKey, qpid::framing::FieldTable* args); + virtual void route(Message::shared_ptr& msg, const std::string& routingKey, qpid::framing::FieldTable* args); virtual ~DirectExchange(); }; |