diff options
| -rw-r--r-- | python/qmf/console.py | 6 | ||||
| -rw-r--r-- | ruby/lib/qpid/qmf.rb | 7 |
2 files changed, 12 insertions, 1 deletions
diff --git a/python/qmf/console.py b/python/qmf/console.py index c3ef0a1a50..315d581fc6 100644 --- a/python/qmf/console.py +++ b/python/qmf/console.py @@ -609,6 +609,12 @@ class Session: brokerList = self.brokers for broker in brokerList: broker._waitForStable() + if broker.isConnected(): + if "_package" not in kwargs or "_class" not in kwargs or \ + kwargs["_package"] != "org.apache.qpid.broker" or \ + kwargs["_class"] != "agent": + self.getObjects(_package = "org.apache.qpid.broker", _class = "agent", + _agent = broker.getAgent(1,0)) agentList = [] if "_agent" in kwargs: diff --git a/ruby/lib/qpid/qmf.rb b/ruby/lib/qpid/qmf.rb index b9961c9a18..1107f4384e 100644 --- a/ruby/lib/qpid/qmf.rb +++ b/ruby/lib/qpid/qmf.rb @@ -333,7 +333,12 @@ module Qpid::Qmf else broker_list = @brokers end - broker_list.each { |broker| broker.wait_for_stable } + broker_list.each { |broker| + broker.wait_for_stable + if kwargs[:package] != "org.apache.qpid.broker" or kwargs[:class] != "agent" + objects(:agent => broker.agent(1,0), :package => "org.apache.qpid.broker", :class => "agent") if broker.connected? + end + } agent_list = [] if kwargs.include?(:agent) |