You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ns...@apache.org on 2009/05/28 23:40:24 UTC
svn commit: r779779 - /qpid/trunk/qpid/python/qmf/console.py
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