summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/FanOutExchange.cpp
diff options
context:
space:
mode:
authorTed Ross <tross@apache.org>2008-07-08 21:54:20 +0000
committerTed Ross <tross@apache.org>2008-07-08 21:54:20 +0000
commit391608a73f18a1797ab0c358f0a94364dc888eb2 (patch)
treec7f26ec2072884a2e94a767a3d4f29d76c4e81c7 /cpp/src/qpid/broker/FanOutExchange.cpp
parent5515803c70dfeff04c190533e7f0187a0e732bf4 (diff)
downloadqpid-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.cpp16
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 ());