svn commit: r612034 - in /webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes: MembershipManager.java TribesClusterManager.java

[azeez]

Author: azeez
Date: Mon Jan 14 23:45:20 2008
New Revision: 612034

URL: http://svn.apache.org/viewvc?rev=612034&view=rev
Log:
Few minor changes


Modified:
    
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/tribes/MembershipManager.java
URL: 
http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java?rev=612034&r1=612033&r2=612034&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 14 23:45:20 2008
@@ -56,10 +56,6 @@
         return longestLivingMember;
     }
 
-    public synchronized void removeAllMembers() {
-        members.clear();
-    }
-
     public synchronized Member getRandomMember() {
         if (members.size() == 0) {
             return null;

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=612034&r1=612033&r2=612034&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 14 23:45:20 2008
@@ -52,6 +52,7 @@
 import org.apache.catalina.tribes.group.interceptors.OrderInterceptor;
 import org.apache.catalina.tribes.transport.ReceiverBase;
 import org.apache.catalina.tribes.transport.ReplicationTransmitter;
+import org.apache.catalina.tribes.transport.MultiPointSender;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
@@ -140,8 +141,10 @@
         if (maxRetriesParam != null) {
             maxRetries = Integer.parseInt((String) maxRetriesParam.getValue());
         }
-        ((ReplicationTransmitter) channel.getChannelSender()).
-                getTransport().setMaxRetryAttempts(maxRetries);
+        ReplicationTransmitter replicationTransmitter =
+                (ReplicationTransmitter) channel.getChannelSender();
+        MultiPointSender multiPointSender = 
replicationTransmitter.getTransport();
+        multiPointSender.setMaxRetryAttempts(maxRetries);
 
         // Set the IP address that will be advertised by this node
         String localIP = 
System.getProperty(ClusteringConstants.LOCAL_IP_ADDRESS);
@@ -197,6 +200,7 @@
 
         // Add a reliable failure detector
         TcpFailureDetector tcpFailureDetector = new TcpFailureDetector();
+        tcpFailureDetector.setPrevious(dfi);
         channel.addInterceptor(tcpFailureDetector);
 
         channel.addChannelListener(channelListener);



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