Shut down thrift on decommission. Patch by brandonwilliams, reviewed by jbellis for CASSANDRA-4086
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/46689e51 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/46689e51 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/46689e51 Branch: refs/heads/trunk Commit: 46689e51b4c5479e7875bf918a820c5e74c3b418 Parents: 0594179 Author: Brandon Williams <[email protected]> Authored: Tue Mar 27 12:25:35 2012 -0500 Committer: Brandon Williams <[email protected]> Committed: Tue Mar 27 12:25:35 2012 -0500 ---------------------------------------------------------------------- .../apache/cassandra/service/StorageService.java | 1 + 1 files changed, 1 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/46689e51/src/java/org/apache/cassandra/service/StorageService.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java index 7f2f988..38f7231 100644 --- a/src/java/org/apache/cassandra/service/StorageService.java +++ b/src/java/org/apache/cassandra/service/StorageService.java @@ -2122,6 +2122,7 @@ public class StorageService implements IEndpointStateChangeSubscriber, StorageSe { public void run() { + stopRPCServer(); Gossiper.instance.stop(); MessagingService.instance().shutdown(); StageManager.shutdownNow();
