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 | 38b7b113a6215cbc145c57359ae08422818420ad (patch) | |
| tree | d7781bcfc54543e58fe55ec73bdc7fbc60138e18 /qpid/python/qmf | |
| parent | c287f7df53ace7c36b5b98bbda63c8a77ba0c1fa (diff) | |
| download | qpid-python-38b7b113a6215cbc145c57359ae08422818420ad.tar.gz | |
invoke agent-related callbacks upon broker connect/disconnect
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@779779 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python/qmf')
| -rw-r--r-- | qpid/python/qmf/console.py | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/qpid/python/qmf/console.py b/qpid/python/qmf/console.py index ef2ab264eb..de8df06adc 100644 --- a/qpid/python/qmf/console.py +++ b/qpid/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): |