diff --git a/akka-actor/src/main/scala/akka/AkkaException.scala b/akka-actor/src/main/scala/akka/AkkaException.scala
index 542bece2ea..f87453db10 100644
--- a/akka-actor/src/main/scala/akka/AkkaException.scala
+++ b/akka-actor/src/main/scala/akka/AkkaException.scala
@@ -6,7 +6,7 @@ package akka
import akka.actor.newUuid
import java.net.{ InetAddress, UnknownHostException }
-
+
/**
* Akka base Exception. Each Exception gets:
*
diff --git a/akka-cluster/src/main/scala/akka/cluster/Cluster.scala b/akka-cluster/src/main/scala/akka/cluster/Cluster.scala
index 152de0368f..9a26ad985b 100644
--- a/akka-cluster/src/main/scala/akka/cluster/Cluster.scala
+++ b/akka-cluster/src/main/scala/akka/cluster/Cluster.scala
@@ -477,35 +477,35 @@ class DefaultClusterNode private[akka](
def shutdown() {
+ def shutdownNode() {
+ ignore[ZkNoNodeException](zkClient.deleteRecursive(membershipNodePath))
+
+ locallyCachedMembershipNodes.clear()
+
+ nodeConnections.toList.foreach({
+ case (_, (address, _)) ⇒
+ Actor.remote.shutdownClientConnection(address) // shut down client connections
+ })
+
+ remoteService.shutdown() // shutdown server
+
+ remoteClientLifeCycleListener.stop()
+ remoteDaemon.stop()
+
+ // for monitoring remote listener
+ registry.local.actors.filter(remoteService.hasListener).foreach(_.stop())
+
+ nodeConnections.clear()
+
+ disconnect()
+ EventHandler.info(this, "Cluster node shut down [%s]".format(nodeAddress))
+ }
+
isConnected.switchOff {
shutdownNode()
}
}
- private def shutdownNode() {
- ignore[ZkNoNodeException](zkClient.deleteRecursive(membershipNodePath))
-
- locallyCachedMembershipNodes.clear()
-
- nodeConnections.toList.foreach({
- case (_, (address, _)) ⇒
- Actor.remote.shutdownClientConnection(address) // shut down client connections
- })
-
- remoteService.shutdown() // shutdown server
-
- remoteClientLifeCycleListener.stop()
- remoteDaemon.stop()
-
- // for monitoring remote listener
- registry.local.actors.filter(remoteService.hasListener).foreach(_.stop())
-
- nodeConnections.clear()
-
- disconnect()
- EventHandler.info(this, "Cluster node shut down [%s]".format(nodeAddress))
- }
-
def disconnect(): ClusterNode = {
zkClient.unsubscribeAll()
zkClient.close()