diff options
author | Nuno Santos <nsantos@apache.org> | 2009-05-28 21:40:23 +0000 |
---|---|---|
committer | Nuno Santos <nsantos@apache.org> | 2009-05-28 21:40:23 +0000 |
commit | 7e14af310cbf9a73a3c01ba4b1918c7331de3448 (patch) | |
tree | 1c36f49160d97e6c2b080c9d25637f35a0e12c64 /python/qmf/console.py | |
parent | 3cd98a374cde935d7056a35811e348f81e3214fe (diff) | |
download | qpid-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.py | 7 |
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): |