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

Removed WS and de-commented enforcer

Browse source
This commit is contained in:
Viktor Klang 2010-01-28 00:05:41 +01:00
parent 3be43c4c42
commit 45de505e4b
2 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-core/src/main/scala/remote/Cluster.scala
View file

@ -29,7 +29,7 @@ trait Cluster {
}
trait ClusterActor extends Actor with Cluster {
val name = config.getString("akka.remote.cluster.name") getOrElse "default"
val name = config.getString("akka.remote.cluster.name") getOrElse "default"
}
private[remote] object ClusterActor {
@ -139,7 +139,7 @@ abstract class BasicClusterActor extends ClusterActor {
}
protected def broadcast[T <: AnyRef](msg: T): Unit =
if (!remotes.isEmpty) toAllNodes(Cluster.serializer out msg)
if (!remotes.isEmpty) toAllNodes(Cluster.serializer out msg)
def lookup[T](handleRemoteAddress: PartialFunction[RemoteAddress, T]): Option[T] =
remotes.values.toList.flatMap(_.endpoints).find(handleRemoteAddress isDefinedAt _).map(handleRemoteAddress)