[jboss-cvs] JBoss Messaging SVN: r8207 - branches/port1842/src/main/org/jboss/messaging/core/impl/postoffice.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Sat Feb 5 19:15:13 EST 2011


Author: jbertram at redhat.com
Date: 2011-02-05 19:15:12 -0500 (Sat, 05 Feb 2011)
New Revision: 8207

Modified:
   branches/port1842/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java
Log:
added some DEBUG logging for cluster health DB operations

Modified: branches/port1842/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java
===================================================================
--- branches/port1842/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java	2011-02-05 20:19:55 UTC (rev 8206)
+++ branches/port1842/src/main/org/jboss/messaging/core/impl/postoffice/MessagingPostOffice.java	2011-02-06 00:15:12 UTC (rev 8207)
@@ -696,12 +696,21 @@
                {
                   //writing timestamp
                   ps = conn.prepareStatement(getSQLStatement("UPDATE_TIMESTAMP"));
-   
+                  
                   ps.setLong(1, System.currentTimeMillis());
                   ps.setInt(2, thisNodeID);
    
-                  ps.executeUpdate();
+                  int result = ps.executeUpdate();
                   
+                  if (result > 0) 
+                  {
+                     log.debug("Successfully updated cluster health timestamp for node " + thisNodeID);
+                  } 
+                  else if (result == 0) 
+                  {
+                     log.debug("Cluster health timestamp update for node " + thisNodeID + " failed!");
+                  }
+                  
                   timestampDone = true;
                   
                   synchronized (clusterState)
@@ -718,6 +727,7 @@
                         int nodeState = result.getInt(3);
    
                         clusterState.addNode(nodeID, timestamp, nodeState);
+                        log.debug("Added cluster node state: nodeID = " + nodeID + ", timestamp = " + timestamp + ", nodeState = " + nodeState);
                      }
                   }
                }



More information about the jboss-cvs-commits mailing list