From ac3f850123c903f00c163d6d2dbad22d98aec7a2 Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Thu, 28 Feb 2008 18:55:21 +0000 Subject: QPID-820 from tross git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@632087 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/management/ManagementExchange.cpp | 23 +++++------------------ 1 file changed, 5 insertions(+), 18 deletions(-) (limited to 'cpp/src/qpid/management/ManagementExchange.cpp') 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; -- cgit v1.2.1