summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/management/ManagementExchange.cpp
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2008-02-28 18:55:21 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2008-02-28 18:55:21 +0000
commitac3f850123c903f00c163d6d2dbad22d98aec7a2 (patch)
tree2e622a3e9349a9062454d16bf4bca83a5a3e9d90 /cpp/src/qpid/management/ManagementExchange.cpp
parent1820dd421a096ed184a08deee9512e809312fed2 (diff)
downloadqpid-python-ac3f850123c903f00c163d6d2dbad22d98aec7a2.tar.gz
QPID-820 from tross
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@632087 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/management/ManagementExchange.cpp')
-rw-r--r--cpp/src/qpid/management/ManagementExchange.cpp23
1 files changed, 5 insertions, 18 deletions
diff --git a/cpp/src/qpid/management/ManagementExchange.cpp b/cpp/src/qpid/management/ManagementExchange.cpp
index ee18f026e7..c589aefba0 100644
--- a/cpp/src/qpid/management/ManagementExchange.cpp
+++ b/cpp/src/qpid/management/ManagementExchange.cpp
@@ -36,28 +36,15 @@ ManagementExchange::ManagementExchange (const std::string& _name,
Exchange (_name, _durable, _args, _parent),
TopicExchange(_name, _durable, _args, _parent) {}
-
-bool ManagementExchange::bind (Queue::shared_ptr queue,
- const string& routingKey,
- const FieldTable* args)
-{
- bool result = TopicExchange::bind (queue, routingKey, args);
-
- // Notify the management agent that a new management client has bound to the
- // exchange.
- if (result)
- managementAgent->clientAdded ();
-
- return result;
-}
-
void ManagementExchange::route (Deliverable& msg,
const string& routingKey,
const FieldTable* args)
{
- // Intercept management commands
- if (routingKey.length () > 7 &&
- routingKey.substr (0, 7).compare ("method.") == 0)
+ // Intercept management agent commands
+ if ((routingKey.length () > 6 &&
+ routingKey.substr (0, 6).compare ("agent.") == 0) ||
+ (routingKey.length () == 5 &&
+ routingKey.substr (0, 5).compare ("agent") == 0))
{
managementAgent->dispatchCommand (msg, routingKey, args);
return;