diff options
| author | Ted Ross <tross@apache.org> | 2008-11-13 04:15:15 +0000 |
|---|---|---|
| committer | Ted Ross <tross@apache.org> | 2008-11-13 04:15:15 +0000 |
| commit | b15caaa061091efcecfd1e8704e6f2c6bde4e03e (patch) | |
| tree | f523e1396f2994b97fb98b0db91a266e82e67d99 /qpid/python | |
| parent | 4a32a1d626f30b7679eaecdf98d0c3330b4d4c08 (diff) | |
| download | qpid-python-b15caaa061091efcecfd1e8704e6f2c6bde4e03e.tar.gz | |
Updated qmf-agent API to allow user to specify uid, password, mechanism, and protocol.
Fixed qmf-console bug related to routing keys of object messages.
Pass the binding key into the management agent to allow for selective broadcast
of object data.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@713631 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python')
| -rw-r--r-- | qpid/python/qpid/qmfconsole.py | 13 |
1 files changed, 3 insertions, 10 deletions
diff --git a/qpid/python/qpid/qmfconsole.py b/qpid/python/qpid/qmfconsole.py index 7d7aeee44f..06517d0aaf 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 """ @@ -374,7 +374,7 @@ class Session: if self.rcvEvents: keyList.append("console.event.#") if self.rcvHeartbeats: - keyList.append("console.heartbeat") + keyList.append("console.heartbeat.#") return keyList def _handleBrokerConnect(self, broker): @@ -692,13 +692,6 @@ class Package: def __init__(self, name): self.name = name -class ClassKey: - """ """ - def __init__(self, package, className, hash): - self.package = package - self.className = className - self.hash = hash - class SchemaClass: """ """ CLASS_KIND_TABLE = 1 |