svn commit: r1040329 - in /cassandra/branches/cassandra-0.7: src/java/org/apache/cassandra/net/sink/SinkManager.java test/unit/org/apache/cassandra/service/RemoveTest.java

[jbellis]

Author: jbellis
Date: Mon Nov 29 22:42:39 2010
New Revision: 1040329

URL: http://svn.apache.org/viewvc?rev=1040329&view=rev
Log:
rename SinkManager.addSink -> SinkManager.add
patch by jbellis

Modified:
    
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/sink/SinkManager.java
    
cassandra/branches/cassandra-0.7/test/unit/org/apache/cassandra/service/RemoveTest.java

Modified: 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/sink/SinkManager.java
URL: 
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/sink/SinkManager.java?rev=1040329&r1=1040328&r2=1040329&view=diff
==============================================================================
--- 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/sink/SinkManager.java
 (original)
+++ 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/sink/SinkManager.java
 Mon Nov 29 22:42:39 2010
@@ -28,7 +28,7 @@ public class SinkManager
 {
     private static List<IMessageSink> sinks = new ArrayList<IMessageSink>();
 
-    public static void addSink(IMessageSink ms)
+    public static void add(IMessageSink ms)
     {
         sinks.add(ms);
     }

Modified: 
cassandra/branches/cassandra-0.7/test/unit/org/apache/cassandra/service/RemoveTest.java
URL: 
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/test/unit/org/apache/cassandra/service/RemoveTest.java?rev=1040329&r1=1040328&r2=1040329&view=diff
==============================================================================
--- 
cassandra/branches/cassandra-0.7/test/unit/org/apache/cassandra/service/RemoveTest.java
 (original)
+++ 
cassandra/branches/cassandra-0.7/test/unit/org/apache/cassandra/service/RemoveTest.java
 Mon Nov 29 22:42:39 2010
@@ -111,7 +111,7 @@ public class RemoveTest extends CleanupH
 
         final String token = 
partitioner.getTokenFactory().toString(endpointTokens.get(5));
         ReplicationSink rSink = new ReplicationSink();
-        SinkManager.addSink(rSink);
+        SinkManager.add(rSink);
 
         // start removal in background and send replication confirmations
         final AtomicBoolean success = new AtomicBoolean(false);
@@ -159,8 +159,8 @@ public class RemoveTest extends CleanupH
 
         NotificationSink nSink = new NotificationSink();
         ReplicationSink rSink = new ReplicationSink();
-        SinkManager.addSink(nSink);
-        SinkManager.addSink(rSink);
+        SinkManager.add(nSink);
+        SinkManager.add(rSink);
 
         assertEquals(0, tmd.getLeavingEndpoints().size());