Change the name to a more appropriate name
authorfhanik <fhanik@13f79535-47bb-0310-9956-ffa450edef68>
Thu, 26 Apr 2007 16:52:29 +0000 (16:52 +0000)
committerfhanik <fhanik@13f79535-47bb-0310-9956-ffa450edef68>
Thu, 26 Apr 2007 16:52:29 +0000 (16:52 +0000)
git-svn-id: https://svn.apache.org/repos/asf/tomcat/tc6.0.x/trunk@532800 13f79535-47bb-0310-9956-ffa450edef68

java/org/apache/catalina/tribes/transport/MultiPointSender.java
java/org/apache/catalina/tribes/transport/ReplicationTransmitter.java
java/org/apache/catalina/tribes/transport/bio/MultipointBioSender.java
java/org/apache/catalina/tribes/transport/bio/PooledMultiSender.java
java/org/apache/catalina/tribes/transport/nio/ParallelNioSender.java
java/org/apache/catalina/tribes/transport/nio/PooledParallelSender.java

index 1a5f1e7..e1b1c4a 100644 (file)
@@ -33,6 +33,6 @@ public interface MultiPointSender extends DataSender
     public void setTxBufSize(int size);
     public void setMaxRetryAttempts(int attempts);
     public void setDirectBuffer(boolean directBuf);
-    public void memberAdded(Member member);
-    public void memberDisappeared(Member member);
+    public void add(Member member);
+    public void remove(Member member);
 }
index 04065c7..cb3e854 100644 (file)
@@ -116,7 +116,7 @@ public class ReplicationTransmitter implements ChannelSender {
      * @see org.apache.catalina.tribes.ClusterSender#add(org.apache.catalina.tribes.Member)
      */
     public synchronized void add(Member member) {
-        getTransport().memberAdded(member);
+        getTransport().add(member);
     }
 
     /**
@@ -125,7 +125,7 @@ public class ReplicationTransmitter implements ChannelSender {
      * @see org.apache.catalina.tribes.ClusterSender#remove(org.apache.catalina.tribes.Member)
      */
     public synchronized void remove(Member member) {
-        getTransport().memberDisappeared(member);
+        getTransport().remove(member);
     }
 
     // ------------------------------------------------------------- protected
index 34924ae..3672a3c 100644 (file)
@@ -107,11 +107,11 @@ public class MultipointBioSender extends AbstractSender implements MultiPointSen
         if ( x != null ) throw x;
     }
 
-    public void memberAdded(Member member) {
+    public void add(Member member) {
 
     }
 
-    public void memberDisappeared(Member member) {
+    public void remove(Member member) {
         //disconnect senders
         BioSender sender = (BioSender)bioSenders.remove(member);
         if ( sender != null ) sender.disconnect();
index 6491073..a9f864d 100644 (file)
@@ -70,11 +70,11 @@ public class PooledMultiSender extends PooledSender {
     }
 
 
-    public void memberAdded(Member member) {
+    public void add(Member member) {
 
     }
 
-    public void memberDisappeared(Member member) {
+    public void remove(Member member) {
         //disconnect senders
     } 
 
index c606e44..2b41edf 100644 (file)
@@ -256,11 +256,11 @@ public class ParallelNioSender extends AbstractSender implements MultiPointSende
         if ( x != null ) throw x;
     }
     
-    public void memberAdded(Member member) {
+    public void add(Member member) {
         
     }
     
-    public void memberDisappeared(Member member) {
+    public void remove(Member member) {
         //disconnect senders
         NioSender sender = (NioSender)nioSenders.remove(member);
         if ( sender != null ) sender.disconnect();
index 2403fb0..534aeb2 100644 (file)
@@ -73,11 +73,11 @@ public class PooledParallelSender extends PooledSender implements MultiPointSend
         super.connect();
     }
 
-    public void memberAdded(Member member) {
+    public void add(Member member) {
     
     }
     
-    public void memberDisappeared(Member member) {
+    public void remove(Member member) {
         //disconnect senders
     }    
 }
\ No newline at end of file