diff --git a/akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenDispatcher.scala b/akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenDispatcher.scala index ed8fa9acfe..705c3ee142 100644 --- a/akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenDispatcher.scala +++ b/akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenDispatcher.scala @@ -89,7 +89,7 @@ class ExecutorBasedEventDrivenDispatcher(_name: String) extends MessageDispatche } def shutdown = if (active) { - log.debug("Shutting down ThreadBasedDispatcher [%s]", name) + log.debug("Shutting down ExecutorBasedEventDrivenDispatcher [%s]", name) executor.shutdownNow active = false references.clear diff --git a/akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenWorkStealingDispatcher.scala b/akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenWorkStealingDispatcher.scala index bf05b4549e..f828a47636 100644 --- a/akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenWorkStealingDispatcher.scala +++ b/akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenWorkStealingDispatcher.scala @@ -178,7 +178,7 @@ class ExecutorBasedEventDrivenWorkStealingDispatcher(_name: String) extends Mess } def shutdown = if (active) { - log.debug("Shutting down ThreadBasedDispatcher [%s]", name) + log.debug("Shutting down ExecutorBasedEventDrivenWorkStealingDispatcher [%s]", name) executor.shutdownNow active = false references.clear diff --git a/akka-core/src/main/scala/dispatch/ThreadBasedDispatcher.scala b/akka-core/src/main/scala/dispatch/ThreadBasedDispatcher.scala index 27eb3a1ea5..8b1463f655 100644 --- a/akka-core/src/main/scala/dispatch/ThreadBasedDispatcher.scala +++ b/akka-core/src/main/scala/dispatch/ThreadBasedDispatcher.scala @@ -42,7 +42,7 @@ class ThreadBasedDispatcher private[akka] (val name: String, val messageHandler: def isShutdown = !active def shutdown = if (active) { - log.debug("Shutting down ExecutorBasedEventDrivenDispatcher [%s]", name) + log.debug("Shutting down ThreadBasedDispatcher [%s]", name) active = false selectorThread.interrupt references.clear