svn commit: r992527 - in /cassandra/trunk/src/java/org/apache/cassandra/gms: Gossiper.java IEndpointStateChangePublisher.java

[jbellis]

Author: jbellis
Date: Sat Sep  4 03:49:45 2010
New Revision: 992527

URL: http://svn.apache.org/viewvc?rev=992527&view=rev
Log:
r/m unused IEndpointStateChangePublisher interface.  patch by jbellis

Removed:
    
cassandra/trunk/src/java/org/apache/cassandra/gms/IEndpointStateChangePublisher.java
Modified:
    cassandra/trunk/src/java/org/apache/cassandra/gms/Gossiper.java

Modified: cassandra/trunk/src/java/org/apache/cassandra/gms/Gossiper.java
URL: 
http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/gms/Gossiper.java?rev=992527&r1=992526&r2=992527&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/gms/Gossiper.java (original)
+++ cassandra/trunk/src/java/org/apache/cassandra/gms/Gossiper.java Sat Sep  4 
03:49:45 2010
@@ -46,7 +46,7 @@ import org.slf4j.LoggerFactory;
  * of the three above mentioned messages updates the Failure Detector with the 
liveness information.
  */
 
-public class Gossiper implements IFailureDetectionEventListener, 
IEndpointStateChangePublisher
+public class Gossiper implements IFailureDetectionEventListener
 {
     private class GossipTimerTask extends TimerTask
     {
@@ -151,12 +151,19 @@ public class Gossiper implements IFailur
         FailureDetector.instance.registerFailureDetectionEventListener(this);
     }
 
-    /** Register with the Gossiper for EndpointState notifications */
+    /**
+     * Register for interesting state changes.
+     * @param subscriber module which implements the 
IEndpointStateChangeSubscriber
+     */
     public void register(IEndpointStateChangeSubscriber subscriber)
     {
         subscribers_.add(subscriber);
     }
 
+    /**
+     * Unregister interest for state changes.
+     * @param subcriber module which implements the 
IEndpointStateChangeSubscriber
+     */
     public void unregister(IEndpointStateChangeSubscriber subscriber)
     {
         subscribers_.remove(subscriber);