You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2012/12/04 21:39:42 UTC
[10/10] git commit: switch from Callable-returns-null to Runnable
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.1
Commit: 2e271233ffeaef9881fdc38704051d4879879021
Parents: 3213574
Author: Jonathan Ellis <jb...@apache.org>
Authored: Tue Dec 4 14:37:23 2012 -0600
Committer: Jonathan Ellis <jb...@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;
}
});