diff options
| author | Ted Ross <tross@apache.org> | 2008-07-08 21:54:20 +0000 |
|---|---|---|
| committer | Ted Ross <tross@apache.org> | 2008-07-08 21:54:20 +0000 |
| commit | 391608a73f18a1797ab0c358f0a94364dc888eb2 (patch) | |
| tree | c7f26ec2072884a2e94a767a3d4f29d76c4e81c7 /cpp/src/qpid/broker/FanOutExchange.cpp | |
| parent | 5515803c70dfeff04c190533e7f0187a0e732bf4 (diff) | |
| download | qpid-python-391608a73f18a1797ab0c358f0a94364dc888eb2.tar.gz | |
QPID-1170 - Remove boost dependency from management agent interface
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@674994 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/FanOutExchange.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/FanOutExchange.cpp | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/cpp/src/qpid/broker/FanOutExchange.cpp b/cpp/src/qpid/broker/FanOutExchange.cpp index 3483562292..373e9ab1cc 100644 --- a/cpp/src/qpid/broker/FanOutExchange.cpp +++ b/cpp/src/qpid/broker/FanOutExchange.cpp @@ -28,7 +28,7 @@ using namespace qpid::sys; FanOutExchange::FanOutExchange(const std::string& _name, Manageable* _parent) : Exchange(_name, _parent) { - if (mgmtExchange.get() != 0) + if (mgmtExchange != 0) mgmtExchange->set_type (typeName); } @@ -36,7 +36,7 @@ FanOutExchange::FanOutExchange(const std::string& _name, bool _durable, const FieldTable& _args, Manageable* _parent) : Exchange(_name, _durable, _args, _parent) { - if (mgmtExchange.get() != 0) + if (mgmtExchange != 0) mgmtExchange->set_type (typeName); } @@ -52,9 +52,9 @@ bool FanOutExchange::bind(Queue::shared_ptr queue, const string& /*routingKey*/, if (i == bindings.end()) { Binding::shared_ptr binding (new Binding ("", queue, this)); bindings.push_back(binding); - if (mgmtExchange.get() != 0) { + if (mgmtExchange != 0) { mgmtExchange->inc_bindingCount(); - dynamic_pointer_cast<management::Queue>(queue->GetManagementObject())->inc_bindingCount(); + ((management::Queue*) queue->GetManagementObject())->inc_bindingCount(); } return true; } else { @@ -72,9 +72,9 @@ bool FanOutExchange::unbind(Queue::shared_ptr queue, const string& /*routingKey* if (i != bindings.end()) { bindings.erase(i); - if (mgmtExchange.get() != 0) { + if (mgmtExchange != 0) { mgmtExchange->dec_bindingCount(); - dynamic_pointer_cast<management::Queue>(queue->GetManagementObject())->dec_bindingCount(); + ((management::Queue*) queue->GetManagementObject())->dec_bindingCount(); } return true; } else { @@ -88,11 +88,11 @@ void FanOutExchange::route(Deliverable& msg, const string& /*routingKey*/, const for(std::vector<Binding::shared_ptr>::iterator i = bindings.begin(); i != bindings.end(); ++i, count++){ msg.deliverTo((*i)->queue); - if ((*i)->mgmtBinding.get() != 0) + if ((*i)->mgmtBinding != 0) (*i)->mgmtBinding->inc_msgMatched (); } - if (mgmtExchange.get() != 0) + if (mgmtExchange != 0) { mgmtExchange->inc_msgReceives (); mgmtExchange->inc_byteReceives (msg.contentSize ()); |
