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

Merge pull request #1500 from akka/wip-3210-local-only-∂π

Browse source 
make LocalScope mean “purely local” and avoid Props serialization check,...
This commit is contained in:
Roland Kuhn 2013-05-30 08:03:32 -07:00
commit 8df8541801
52 changed files with 218 additions and 133 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala
View file

@ -17,6 +17,7 @@ import akka.cluster.MemberStatus._
import akka.cluster.ClusterEvent._
import akka.actor.ActorSelection
import akka.dispatch.{ UnboundedMessageQueueSemantics, RequiresMessageQueue }
import akka.actor.Deploy
/**
* Base trait for all cluster messages. All ClusterMessage's are serializable.
@ -167,7 +168,7 @@ private[cluster] final class ClusterDaemon(settings: ClusterSettings) extends Ac
def receive = {
case msg @ GetClusterCoreRef ⇒ coreSupervisor forward msg
case AddOnMemberUpListener(code) ⇒
context.actorOf(Props(classOf[OnMemberUpListener], code))
context.actorOf(Props(classOf[OnMemberUpListener], code).withDeploy(Deploy.local))
case PublisherCreated(publisher) ⇒
if (settings.MetricsEnabled) {
// metrics must be started after core/publisher to be able