[jboss-cvs] JBoss Messaging SVN: r2841 - trunk/src/main/org/jboss/jms/server/connectionmanager.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2007-07-04 16:30:19 -0400 (Wed, 04 Jul 2007)
New Revision: 2841

Modified:
   trunk/src/main/org/jboss/jms/server/connectionmanager/SimpleConnectionManager.java
Log:
Just adding some tracing I needed

Modified: trunk/src/main/org/jboss/jms/server/connectionmanager/SimpleConnectionManager.java
===================================================================
--- trunk/src/main/org/jboss/jms/server/connectionmanager/SimpleConnectionManager.java	2007-07-04 19:26:26 UTC (rev 2840)
+++ trunk/src/main/org/jboss/jms/server/connectionmanager/SimpleConnectionManager.java	2007-07-04 20:30:19 UTC (rev 2841)
@@ -192,13 +192,21 @@
       }
    }
    
-   // FailoverWaiter implementation ---------------------------------------------------------------
-   
+   // ClusterNotificationListener implementation ---------------------------------------------------
+
+
+   /**
+    * Closing connections that are coming from a failed node
+    * @param notification
+    */
    public void notify(ClusterNotification notification)
 	{
 		if (notification.type == ClusterNotification.TYPE_FAILOVER_START)
 		{
-			try
+
+         log.trace("SimpleConnectionManager was notified about FailoverStart from node " +
+            notification.nodeID);
+         try
 			{
 				//We remove any consumers with the same JVMID as the node that just failed
 				//This will remove any message suckers from a failed node
@@ -211,6 +219,7 @@
 				
 				if (ids == null)
 				{
+               log.trace("Cannot find jvmid map");
 					throw new IllegalStateException("Cannot find jvmid map");
 				}
 				
@@ -220,12 +229,15 @@
 				
 				if (clientVMID == null)
 				{
+               log.error("Cannot find ClientVMID for failed node " + failedNodeID);
 					throw new IllegalStateException("Cannot find clientVMID for failed node " + failedNodeID);
 				}
 				
 				//Close the consumers corresponding to that VM
-				
-				closeConsumersForClientVMID(clientVMID);
+
+            log.trace("Closing consumers for clientVMID=" + clientVMID);
+
+            closeConsumersForClientVMID(clientVMID);
 			}
 			catch (Exception e)
 			{