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

=clu #3533 Harden cluster startup error handling

Browse source
This commit is contained in:
Patrik Nordwall 2013-09-17 16:52:08 +02:00
parent 6246099694
commit 5e1913cac2
1 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-cluster/src/main/scala/akka/cluster/Cluster.scala
View file

@ -166,9 +166,12 @@ class Cluster(val system: ExtendedActorSystem) extends Extension {
Await.result((clusterDaemons ? InternalClusterAction.GetClusterCoreRef).mapTo[ActorRef], timeout.duration) Await.result((clusterDaemons ? InternalClusterAction.GetClusterCoreRef).mapTo[ActorRef], timeout.duration)
} catch { } catch {
case NonFatal(e) ⇒ case NonFatal(e) ⇒
log.error(e, "Failed to startup Cluster") log.error(e, "Failed to startup Cluster. You can try to increase 'akka.actor.creation-timeout'.")
shutdown() shutdown()
throw e // don't re-throw, that would cause the extension to be re-recreated
// from shutdown() or other places, which may result in
// InvalidActorNameException: actor name [cluster] is not unique
system.deadLetters
} }
} }