diff options
| author | Ted Ross <tross@apache.org> | 2008-11-20 14:51:45 +0000 |
|---|---|---|
| committer | Ted Ross <tross@apache.org> | 2008-11-20 14:51:45 +0000 |
| commit | 7ad3988e599da508eb782ca84d97033b33692ac4 (patch) | |
| tree | b0447ad140b4fea947d324ff0b33e14b633a35a3 /qpid/python | |
| parent | 3531d11f4fe66237ea0f960228fabf995b88d6f6 (diff) | |
| download | qpid-python-7ad3988e599da508eb782ca84d97033b33692ac4.tar.gz | |
QPID-1476 - routing keys used for updates can't be used to discriminate by agent
- Fixed routing keys in agents and binding keys in consoles
- Added some additional debug output for ManagementAgentImpl
- Minor cleanup in the connection close path for ManagementAgentImpl
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@719245 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python')
| -rw-r--r-- | qpid/python/qpid/qmfconsole.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/python/qpid/qmfconsole.py b/qpid/python/qpid/qmfconsole.py index aa4b149601..bdd93e6f94 100644 --- a/qpid/python/qpid/qmfconsole.py +++ b/qpid/python/qpid/qmfconsole.py @@ -224,7 +224,7 @@ class Session: raise Exception("userBindings option not set for Session") for broker in self.brokers: broker.amqpSession.exchange_bind(exchange="qpid.management", queue=broker.topicName, - binding_key="console.obj.%s.#" % packageName) + binding_key="console.obj.*.*.%s.#" % packageName) def bindClass(self, classKey): """ """ @@ -233,7 +233,7 @@ class Session: pname, cname, hash = classKey for broker in self.brokers: broker.amqpSession.exchange_bind(exchange="qpid.management", queue=broker.topicName, - binding_key="console.obj.%s.%s.#" % (pname, cname)) + binding_key="console.obj.*.*.%s.%s.#" % (pname, cname)) def getAgents(self, broker=None): """ Get a list of currently known agents """ @@ -370,7 +370,7 @@ class Session: if self.rcvObjects and not self.userBindings: keyList.append("console.obj.#") else: - keyList.append("console.obj.org.apache.qpid.broker.agent") + keyList.append("console.obj.*.*.org.apache.qpid.broker.agent") if self.rcvEvents: keyList.append("console.event.#") if self.rcvHeartbeats: |