summaryrefslogtreecommitdiff
path: root/python/qmf/console.py
diff options
context:
space:
mode:
authorNuno Santos <nsantos@apache.org>2009-05-28 21:40:23 +0000
committerNuno Santos <nsantos@apache.org>2009-05-28 21:40:23 +0000
commit7e14af310cbf9a73a3c01ba4b1918c7331de3448 (patch)
tree1c36f49160d97e6c2b080c9d25637f35a0e12c64 /python/qmf/console.py
parent3cd98a374cde935d7056a35811e348f81e3214fe (diff)
downloadqpid-python-7e14af310cbf9a73a3c01ba4b1918c7331de3448.tar.gz
invoke agent-related callbacks upon broker connect/disconnect
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@779779 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qmf/console.py')
-rw-r--r--python/qmf/console.py7
1 files changed, 7 insertions, 0 deletions
diff --git a/python/qmf/console.py b/python/qmf/console.py
index ef2ab264eb..de8df06adc 100644
--- a/python/qmf/console.py
+++ b/python/qmf/console.py
@@ -184,6 +184,9 @@ class Session:
def delBroker(self, broker):
""" Disconnect from a broker. The 'broker' argument is the object
returned from the addBroker call """
+ if self.console:
+ for agent in broker.getAgents():
+ self.console.delAgent(agent)
broker._shutdown()
self.brokers.remove(broker)
del broker
@@ -417,10 +420,14 @@ class Session:
def _handleBrokerConnect(self, broker):
if self.console:
+ for agent in broker.getAgents():
+ self.console.newAgent(agent)
self.console.brokerConnected(broker)
def _handleBrokerDisconnect(self, broker):
if self.console:
+ for agent in broker.getAgents():
+ self.console.delAgent(agent)
self.console.brokerDisconnected(broker)
def _handleBrokerResp(self, broker, codec, seq):