cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbel...@apache.org
Subject [8/10] git commit: switch from Callable-returns-null to Runnable
Date Tue, 04 Dec 2012 20:39:41 GMT
switch from Callable-returns-null to Runnable


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

Branch: refs/heads/cassandra-1.2
Commit: 2e271233ffeaef9881fdc38704051d4879879021
Parents: 3213574
Author: Jonathan Ellis <jbellis@apache.org>
Authored: Tue Dec 4 14:37:23 2012 -0600
Committer: Jonathan Ellis <jbellis@apache.org>
Committed: Tue Dec 4 14:37:23 2012 -0600

----------------------------------------------------------------------
 .../apache/cassandra/service/MigrationManager.java |    5 ++---
 1 files changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/2e271233/src/java/org/apache/cassandra/service/MigrationManager.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/MigrationManager.java b/src/java/org/apache/cassandra/service/MigrationManager.java
index 53c3035..94c0dcc 100644
--- a/src/java/org/apache/cassandra/service/MigrationManager.java
+++ b/src/java/org/apache/cassandra/service/MigrationManager.java
@@ -210,12 +210,11 @@ public class MigrationManager implements IEndpointStateChangeSubscriber
     // Returns a future on the local application of the schema
     private static Future<?> announce(final Collection<RowMutation> schema)
     {
-        Future<?> f = StageManager.getStage(Stage.MIGRATION).submit(new Callable<Object>()
+        Future<?> f = StageManager.getStage(Stage.MIGRATION).submit(new WrappedRunnable()
         {
-            public Object call() throws Exception
+            protected void runMayThrow() throws IOException, ConfigurationException
             {
                 DefsTable.mergeSchema(schema);
-                return null;
             }
         });
 


Mime
View raw message