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@722272 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 11 insertions, 4 deletions

diff --git a/qpid/python/qmf/console.py b/qpid/python/qmf/console.py
index 6b0826f37d..fe329db289 100644
--- a/qpid/python/qmf/console.py
+++ b/qpid/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 []