cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dbros...@apache.org
Subject [1/3] git commit: make StreamSessionConnector a static inner class
Date Sat, 02 Aug 2014 05:46:47 GMT
Repository: cassandra
Updated Branches:
  refs/heads/trunk 35047a8f6 -> a4e8e1656


make StreamSessionConnector a static inner class


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/85b74382
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/85b74382
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/85b74382

Branch: refs/heads/trunk
Commit: 85b74382782767b82cf9b5393770cdf93dd0645d
Parents: 41a85af
Author: Dave Brosius <dbrosius@mebigfatguy.com>
Authored: Sat Aug 2 01:17:50 2014 -0400
Committer: Dave Brosius <dbrosius@mebigfatguy.com>
Committed: Sat Aug 2 01:17:50 2014 -0400

----------------------------------------------------------------------
 src/java/org/apache/cassandra/streaming/StreamCoordinator.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/85b74382/src/java/org/apache/cassandra/streaming/StreamCoordinator.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/streaming/StreamCoordinator.java b/src/java/org/apache/cassandra/streaming/StreamCoordinator.java
index 4a6b193..14dad29 100644
--- a/src/java/org/apache/cassandra/streaming/StreamCoordinator.java
+++ b/src/java/org/apache/cassandra/streaming/StreamCoordinator.java
@@ -183,7 +183,7 @@ public class StreamCoordinator
         return data;
     }
 
-    private class StreamSessionConnector implements Runnable
+    private static class StreamSessionConnector implements Runnable
     {
         private final StreamSession session;
         public StreamSessionConnector(StreamSession session)
@@ -191,6 +191,7 @@ public class StreamCoordinator
             this.session = session;
         }
 
+        @Override
         public void run()
         {
             session.start();


Mime
View raw message