[rhmessaging-commits] rhmessaging commits: r2046 - in mgmt: mint/python/mint and 1 other directory.

[rhmessaging-commits at lists.jboss.org]

Author: justi9
Date: 2008-05-13 18:44:04 -0400 (Tue, 13 May 2008)
New Revision: 2046

Modified:
   mgmt/cumin/python/cumin/__init__.py
   mgmt/mint/python/mint/__init__.py
Log:
bz438219 - Attempt reconnect if a broker conection closes



Modified: mgmt/cumin/python/cumin/__init__.py
===================================================================
--- mgmt/cumin/python/cumin/__init__.py	2008-05-13 21:54:11 UTC (rev 2045)
+++ mgmt/cumin/python/cumin/__init__.py	2008-05-13 22:44:04 UTC (rev 2046)
@@ -32,6 +32,11 @@
         self.model = CuminModel(self, data_uri, spec_path)
         self.broker_connect_thread = BrokerConnectThread(self.model)
 
+        def closeListener(*args):
+            self.broker_connect_thread.prompt()
+
+        self.model.data.setCloseListener(closeListener)
+
         self.main_page = CuminPage(self, "index.html")
         self.add_page(self.main_page)
         self.set_default_page(self.main_page)

Modified: mgmt/mint/python/mint/__init__.py
===================================================================
--- mgmt/mint/python/mint/__init__.py	2008-05-13 21:54:11 UTC (rev 2045)
+++ mgmt/mint/python/mint/__init__.py	2008-05-13 22:44:04 UTC (rev 2046)
@@ -445,9 +445,7 @@
   def closeCallback(self, brokerId, data):
     self.log("\nCLOSE---------------------------------------------------")
     self.log("BrokerId=%s , Data=%s" % (brokerId, data))
-    conn = self.connections[brokerId]
-    if (conn and conn.isOpen()):
-      conn.close()
+    del self.connections[brokerId]
     if (self.connCloseListener != None):
       self.connCloseListener(brokerId, data)
     self.log("END CLOSE---------------------------------------------------\n")