diff options
author | Ted Ross <tross@apache.org> | 2008-12-01 22:53:46 +0000 |
---|---|---|
committer | Ted Ross <tross@apache.org> | 2008-12-01 22:53:46 +0000 |
commit | 074c5284574d41224a85f11f2b7a972138ba3cd5 (patch) | |
tree | 2c8b483c22b721d5c2a620ea4fb96fcbdbe6f58f /python/qmf/console.py | |
parent | d79ddcce46c737af1be82a093446bc71e22138ea (diff) | |
download | qpid-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.py | 15 |
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 [] |