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

Additional tidying

Browse source
This commit is contained in:
Viktor Klang 2009-12-24 14:30:49 +01:00
parent d037f2a915
commit b7b36c22fc
1 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
akka-comet/src/main/scala/AkkaClusterBroadcastFilter.scala
View file

@ -9,8 +9,8 @@ import se.scalablesolutions.akka.remote.{Cluster}
import org.atmosphere.cpr.{ClusterBroadcastFilter,Broadcaster}
import scala.reflect.{BeanProperty}
sealed trait AkkaClusterBroadcastMessage
case class BroadcastMessage(val name : String, val msg : AnyRef) extends AkkaClusterBroadcastMessage
sealed trait AkkaClusterCometBroadcastMessage
case class BroadcastMessage(val name : String, val msg : AnyRef) extends AkkaClusterCometBroadcastMessage
class AkkaClusterBroadcastFilter extends Actor with ClusterBroadcastFilter[AnyRef] {
@BeanProperty var clusterName = ""
@ -27,12 +27,12 @@ class AkkaClusterBroadcastFilter extends Actor with ClusterBroadcastFilter[AnyRe
case _ => {
Cluster.relayMessage(classOf[AkkaClusterBroadcastFilter],BroadcastMessage(clusterName,o))
o
}
}
}
}
}
def receive = {
case bm@BroadcastMessage(c,m) if (c == clusterName) && (broadcaster ne null) => broadcaster broadcast bm
case bm@BroadcastMessage(c,_) if (c == clusterName) && (broadcaster ne null) => broadcaster broadcast bm
case _ =>
}