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

Make sure dispatcher isnt changed on actor restart

Browse source
This commit is contained in:
Viktor Klang 2010-08-27 16:20:21 +02:00
parent 35cc621863
commit a23159fece
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-core/src/main/scala/actor/ActorRef.scala
View file

@ -742,9 +742,11 @@ class LocalActorRef private[akka](
* Sets the dispatcher for this actor. Needs to be invoked before the actor is started.
*/
def dispatcher_=(md: MessageDispatcher): Unit = guard.withGuard {
if (!isRunning || isBeingRestarted) _dispatcher = md
else throw new ActorInitializationException(
if (!isBeingRestarted) {
if (!isRunning) _dispatcher = md
else throw new ActorInitializationException(
"Can not swap dispatcher for " + toString + " after it has been started")
}
}
/**
@ -1141,7 +1143,6 @@ class LocalActorRef private[akka](
freshActor.initTransactionalState
actorInstance.set(freshActor)
if (failedActor.isInstanceOf[TypedActor]) failedActor.asInstanceOf[TypedActor].swapInstanceInProxy(freshActor)
if (dispatcher.isShutdown) dispatcher.start
Actor.log.debug("Invoking 'postRestart' for new actor instance [%s].", id)
freshActor.postRestart(reason)
}