summaryrefslogtreecommitdiff
path: root/python/qmf/console.py
diff options
context:
space:
mode:
authorTed Ross <tross@apache.org>2008-12-01 22:53:46 +0000
committerTed Ross <tross@apache.org>2008-12-01 22:53:46 +0000
commit074c5284574d41224a85f11f2b7a972138ba3cd5 (patch)
tree2c8b483c22b721d5c2a620ea4fb96fcbdbe6f58f /python/qmf/console.py
parentd79ddcce46c737af1be82a093446bc71e22138ea (diff)
downloadqpid-python-074c5284574d41224a85f11f2b7a972138ba3cd5.tar.gz
Gets of specific object-ids should only involve the agent(s) that own
the object id. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722272 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qmf/console.py')
-rw-r--r--python/qmf/console.py15
1 files changed, 11 insertions, 4 deletions
diff --git a/python/qmf/console.py b/python/qmf/console.py
index 6b0826f37d..fe329db289 100644
--- a/python/qmf/console.py
+++ b/python/qmf/console.py
@@ -302,10 +302,17 @@ class Session:
if agent.broker.isConnected():
agentList.append(agent)
else:
- for broker in brokerList:
- for agent in broker.getAgents():
- if agent.broker.isConnected():
- agentList.append(agent)
+ if "_objectId" in kwargs:
+ oid = kwargs["_objectId"]
+ for broker in brokerList:
+ for agent in broker.getAgents():
+ if agent.getBrokerBank() == oid.getBrokerBank() and agent.getAgentBank() == oid.getAgentBank():
+ agentList.append(agent)
+ else:
+ for broker in brokerList:
+ for agent in broker.getAgents():
+ if agent.broker.isConnected():
+ agentList.append(agent)
if len(agentList) == 0:
return []