From 4017a86b4c110bb6ab02afa87629aaf10f2e49ba Mon Sep 17 00:00:00 2001
From: Peter Veentjer <alarmnmmer@gmail.com>
Date: Fri, 15 Jul 2011 10:59:29 +0300
Subject: [PATCH] 1025: some cleanup

---
 .../src/main/scala/akka/AkkaException.scala   |  2 +-
 .../src/main/scala/akka/cluster/Cluster.scala | 48 +++++++++----------
 2 files changed, 25 insertions(+), 25 deletions(-)

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:
  * <ul>
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()