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

Removed MessageInvoker

Browse source
This commit is contained in:
Jonas Bonér 2010-06-01 09:27:14 +02:00
parent d109255c9f
commit dbad1f461f
1 changed files with 1 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-core/src/main/scala/dispatch/MessageHandling.scala
View file

@ -53,10 +53,6 @@ trait MessageQueue {
def append(handle: MessageInvocation) def append(handle: MessageInvocation)
} }
trait MessageInvoker {
def invoke(message: MessageInvocation)
}
trait MessageDispatcher extends Logging { trait MessageDispatcher extends Logging {
protected val references = new ConcurrentHashMap[String, ActorRef] protected val references = new ConcurrentHashMap[String, ActorRef]
def dispatch(invocation: MessageInvocation) def dispatch(invocation: MessageInvocation)
@ -65,8 +61,7 @@ trait MessageDispatcher extends Logging {
def register(actorRef: ActorRef) = references.put(actorRef.uuid, actorRef) def register(actorRef: ActorRef) = references.put(actorRef.uuid, actorRef)
def unregister(actorRef: ActorRef) = { def unregister(actorRef: ActorRef) = {
references.remove(actorRef.uuid) references.remove(actorRef.uuid)
if (canBeShutDown) if (canBeShutDown) shutdown // shut down in the dispatcher's references is zero
shutdown // shut down in the dispatcher's references is zero
} }
def canBeShutDown: Boolean = references.isEmpty def canBeShutDown: Boolean = references.isEmpty
def isShutdown: Boolean def isShutdown: Boolean