svn commit: r609665 - in /webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering: context/ClusteringContextListener.java tribes/ChannelListener.java tribes/MembershipManager.java tribes/TribesClusterManager.java

[azeez]

Author: azeez
Date: Mon Jan  7 08:19:40 2008
New Revision: 609665

URL: http://svn.apache.org/viewvc?rev=609665&view=rev
Log:
Need to initialize the longest alive member


Modified:
    
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/context/ClusteringContextListener.java
    
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/ChannelListener.java
    
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java
    
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java

Modified: 
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/context/ClusteringContextListener.java
URL: 
http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/context/ClusteringContextListener.java?rev=609665&r1=609664&r2=609665&view=diff
==============================================================================
--- 
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/context/ClusteringContextListener.java
 (original)
+++ 
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/context/ClusteringContextListener.java
 Mon Jan  7 08:19:40 2008
@@ -47,7 +47,7 @@
             try {
                 sender.sendToGroup(command);
             } catch (ClusteringFault e) {
-                log.error(e);
+                log.error("Cannot send context removed message to cluster", e);
             }
         }
     }

Modified: 
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/ChannelListener.java
URL: 
http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/ChannelListener.java?rev=609665&r1=609664&r2=609665&view=diff
==============================================================================
--- 
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/ChannelListener.java
 (original)
+++ 
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/ChannelListener.java
 Mon Jan  7 08:19:40 2008
@@ -143,7 +143,7 @@
         try {
             processMessage(msg, sender);
         } catch (Exception e) {
-            log.error(e);
+            log.error("Cannot process message", e);
         }
     }
 

Modified: 
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java
URL: 
http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java?rev=609665&r1=609664&r2=609665&view=diff
==============================================================================
--- 
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java
 (original)
+++ 
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java
 Mon Jan  7 08:19:40 2008
@@ -42,7 +42,9 @@
     public synchronized static Member getLongestAliveMember() {
         Member longestAliveMember = null;
         if (members.size() > 0) {
-            long longestAliveTime = ((Member) 
members.get(0)).getMemberAliveTime();
+            Member member0 = (Member) members.get(0);
+            long longestAliveTime = member0.getMemberAliveTime();
+            longestAliveMember = member0;
             for (int i = 0; i < members.size(); i++) {
                 Member member = (Member) members.get(i);
                 if (longestAliveTime < member.getMemberAliveTime()) {

Modified: 
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java
URL: 
http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java?rev=609665&r1=609664&r2=609665&view=diff
==============================================================================
--- 
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java
 (original)
+++ 
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java
 Mon Jan  7 08:19:40 2008
@@ -256,7 +256,7 @@
                     Thread.sleep(tts + 5 * (numberOfTries + 1));
                 }
             } catch (Exception e) {
-                log.error(e);
+                log.error("Cannot get initialization information", e);
                 break;
             }
             members = MembershipManager.getMembers();



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]