From dbad1f461f497914a6603794e3285e62799fbd03 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jonas=20Bon=C3=A9r?= Date: Tue, 1 Jun 2010 09:27:14 +0200 Subject: [PATCH] Removed MessageInvoker --- akka-core/src/main/scala/dispatch/MessageHandling.scala | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/akka-core/src/main/scala/dispatch/MessageHandling.scala b/akka-core/src/main/scala/dispatch/MessageHandling.scala index 8e094fe108..4a40787bd8 100644 --- a/akka-core/src/main/scala/dispatch/MessageHandling.scala +++ b/akka-core/src/main/scala/dispatch/MessageHandling.scala @@ -53,10 +53,6 @@ trait MessageQueue { def append(handle: MessageInvocation) } -trait MessageInvoker { - def invoke(message: MessageInvocation) -} - trait MessageDispatcher extends Logging { protected val references = new ConcurrentHashMap[String, ActorRef] def dispatch(invocation: MessageInvocation) @@ -65,8 +61,7 @@ trait MessageDispatcher extends Logging { def register(actorRef: ActorRef) = references.put(actorRef.uuid, actorRef) def unregister(actorRef: ActorRef) = { references.remove(actorRef.uuid) - if (canBeShutDown) - shutdown // shut down in the dispatcher's references is zero + if (canBeShutDown) shutdown // shut down in the dispatcher's references is zero } def canBeShutDown: Boolean = references.isEmpty def isShutdown: Boolean