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

Make Make Cluster.joinSeedNodes public, see #3468

Browse source
This commit is contained in:
Patrik Nordwall 2013-06-24 11:46:29 +02:00
parent 98afb2bbd2
commit 30d34e20bf
2 changed files with 21 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -236,10 +236,28 @@ class Cluster(val system: ExtendedActorSystem) extends Extension {
/**
* Try to join this cluster node with the node specified by 'address'.
* A 'Join(selfAddress)' command is sent to the node to join.
*
* An actor system can only join a cluster once. Additional attempts will be ignored.
* When it has successfully joined it must be restarted to be able to join another
* cluster or to join the same cluster again.
*/
def join(address: Address): Unit =
clusterCore ! ClusterUserAction.JoinTo(address)
/**
* Join the specified seed nodes without defining them in config.
* Especially useful from tests when Addresses are unknown before startup time.
*
* An actor system can only join a cluster once. Additional attempts will be ignored.
* When it has successfully joined it must be restarted to be able to join another
* cluster or to join the same cluster again.
*
* JAVA API: Use akka.japi.Util.immutableSeq to convert a java.lang.Iterable
* to the type needed for the seedNodes parameter.
*/
def joinSeedNodes(seedNodes: immutable.Seq[Address]): Unit =
clusterCore ! InternalClusterAction.JoinSeedNodes(seedNodes.toVector)
/**
* Send command to issue state transition to LEAVING for the node specified by 'address'.
*/
@ -273,14 +291,6 @@ class Cluster(val system: ExtendedActorSystem) extends Extension {
// ===================== INTERNAL API =====================
// ========================================================
/**
* Make it possible to join the specified seed nodes without defining them
* in config. Especially useful from tests when Addresses are unknown
* before startup time.
*/
private[cluster] def joinSeedNodes(seedNodes: immutable.IndexedSeq[Address]): Unit =
clusterCore ! InternalClusterAction.JoinSeedNodes(seedNodes)
/**
* INTERNAL API.
*