Making walker a def in remote
This commit is contained in:
parent
3e3cf86bdf
commit
26f45a599b
1 changed files with 3 additions and 3 deletions
|
|
@ -33,9 +33,6 @@ class RemoteActorRefProvider(val app: AkkaApplication) extends ActorRefProvider
|
||||||
import java.util.concurrent.ConcurrentHashMap
|
import java.util.concurrent.ConcurrentHashMap
|
||||||
import akka.dispatch.Promise
|
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 local = new LocalActorRefProvider(app)
|
||||||
val remote = new Remote(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 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 defaultDispatcher = app.dispatcher
|
||||||
def defaultTimeout = app.AkkaConfig.ActorTimeout
|
def defaultTimeout = app.AkkaConfig.ActorTimeout
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue