minor fix
This commit is contained in:
parent
4e4786972a
commit
ac8874cdc7
1 changed files with 3 additions and 1 deletions
|
|
@ -267,7 +267,9 @@ object Cluster extends Cluster with Logging {
|
|||
|
||||
def foreach(f: (RemoteAddress) => Unit): Unit = clusterActor.foreach(_.foreach(f))
|
||||
|
||||
def endpoints: Array[RemoteAddress] = clusterActor.end
|
||||
def endpoints: Array[RemoteAddress] = clusterActor
|
||||
.getOrElse(throw new IllegalStateException("No cluster actor is defined"))
|
||||
.endpoints
|
||||
|
||||
def start(): Unit = start(None)
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue