Repository: cassandra Updated Branches: refs/heads/cassandra-2.1 d33e29acc -> 63d1d2968
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/cassandra-2.1 Commit: 85b74382782767b82cf9b5393770cdf93dd0645d Parents: 41a85af Author: Dave Brosius <[email protected]> Authored: Sat Aug 2 01:17:50 2014 -0400 Committer: Dave Brosius <[email protected]> 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();
