qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nsan...@apache.org
Subject svn commit: r779779 - /qpid/trunk/qpid/python/qmf/console.py
Date Thu, 28 May 2009 21:40:24 GMT
Author: nsantos
Date: Thu May 28 21:40:23 2009
New Revision: 779779

URL: http://svn.apache.org/viewvc?rev=779779&view=rev
Log:
invoke agent-related callbacks upon broker connect/disconnect

Modified:
    qpid/trunk/qpid/python/qmf/console.py

Modified: qpid/trunk/qpid/python/qmf/console.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qmf/console.py?rev=779779&r1=779778&r2=779779&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qmf/console.py (original)
+++ qpid/trunk/qpid/python/qmf/console.py Thu May 28 21:40:23 2009
@@ -184,6 +184,9 @@
   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 @@
 
   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):



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message