You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by az...@apache.org on 2008/01/07 17:19:42 UTC
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
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: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org