From 308bf20a7ddf99d9a5b89143c9d6f5ef73fe6876 Mon Sep 17 00:00:00 2001 From: Jan Van Besien Date: Tue, 30 Mar 2010 13:16:36 +0200 Subject: [PATCH] fixed name of dispatcher in log messages --- .../scala/dispatch/ExecutorBasedEventDrivenDispatcher.scala | 2 +- .../ExecutorBasedEventDrivenWorkStealingDispatcher.scala | 2 +- akka-core/src/main/scala/dispatch/ThreadBasedDispatcher.scala | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) 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