raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Added try-finally blocks for each shutdown step in the Gossipper.shutdown method.

Browse source 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
This commit is contained in:
Jonas Bonér 2012-01-31 15:07:15 +01:00
parent 0b59640820
commit 7dbb5e9abb
1 changed files with 10 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

15
akka-cluster/src/main/scala/akka/cluster/Gossiper.scala
View file

@ -174,11 +174,16 @@ case class Gossiper(remote: RemoteActorRefProvider, system: ActorSystemImpl) {
*/
def shutdown() {
if (isRunning.compareAndSet(true, false)) {
log.info("Shutting down Gossiper for [{}]", address)
connectionManager.shutdown()
system.stop(clusterDaemon)
initateGossipCanceller.cancel()
scrutinizeCanceller.cancel()
log.info("Shutting down Gossiper for [{}]...", address)
try connectionManager.shutdown() finally {
try system.stop(clusterDaemon) finally {
try initateGossipCanceller.cancel() finally {
try scrutinizeCanceller.cancel() finally {
log.info("Gossiper for [{}] is shut down", address)
}
}
}
}
}
}