From 26f45a599b9043ff682b8ca414245c84b4c5f15f Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Wed, 26 Oct 2011 16:12:48 +0200 Subject: [PATCH] Making walker a def in remote --- .../src/main/scala/akka/remote/RemoteActorRefProvider.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala b/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala index 4981e5244a..32248ef6a7 100644 --- a/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala +++ b/akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala @@ -33,9 +33,6 @@ class RemoteActorRefProvider(val app: AkkaApplication) extends ActorRefProvider import java.util.concurrent.ConcurrentHashMap import akka.dispatch.Promise - private[akka] val theOneWhoWalksTheBubblesOfSpaceTime: ActorRef = local.theOneWhoWalksTheBubblesOfSpaceTime - private[akka] def terminationFuture = new DefaultPromise[AkkaApplication.ExitStatus](Timeout.never)(app.dispatcher) - val local = new LocalActorRefProvider(app) val remote = new Remote(app) @@ -43,6 +40,9 @@ class RemoteActorRefProvider(val app: AkkaApplication) extends ActorRefProvider private val remoteDaemonConnectionManager = new RemoteConnectionManager(app, remote) + private[akka] def theOneWhoWalksTheBubblesOfSpaceTime: ActorRef = local.theOneWhoWalksTheBubblesOfSpaceTime + private[akka] def terminationFuture = new DefaultPromise[AkkaApplication.ExitStatus](Timeout.never)(app.dispatcher) + def defaultDispatcher = app.dispatcher def defaultTimeout = app.AkkaConfig.ActorTimeout