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

fixed name of dispatcher in log messages

Browse source
This commit is contained in:
Jan Van Besien 2010-03-30 13:16:36 +02:00
parent 62cdb9fc23
commit 308bf20a7d
3 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenDispatcher.scala
View file

@ -89,7 +89,7 @@ class ExecutorBasedEventDrivenDispatcher(_name: String) extends MessageDispatche
} }
def shutdown = if (active) { def shutdown = if (active) {
log.debug("Shutting down ThreadBasedDispatcher [%s]", name) log.debug("Shutting down ExecutorBasedEventDrivenDispatcher [%s]", name)
executor.shutdownNow executor.shutdownNow
active = false active = false
references.clear references.clear

2
akka-core/src/main/scala/dispatch/ExecutorBasedEventDrivenWorkStealingDispatcher.scala
View file

@ -178,7 +178,7 @@ class ExecutorBasedEventDrivenWorkStealingDispatcher(_name: String) extends Mess
} }
def shutdown = if (active) { def shutdown = if (active) {
log.debug("Shutting down ThreadBasedDispatcher [%s]", name) log.debug("Shutting down ExecutorBasedEventDrivenWorkStealingDispatcher [%s]", name)
executor.shutdownNow executor.shutdownNow
active = false active = false
references.clear references.clear

2
akka-core/src/main/scala/dispatch/ThreadBasedDispatcher.scala
View file

@ -42,7 +42,7 @@ class ThreadBasedDispatcher private[akka] (val name: String, val messageHandler:
def isShutdown = !active def isShutdown = !active
def shutdown = if (active) { def shutdown = if (active) {
log.debug("Shutting down ExecutorBasedEventDrivenDispatcher [%s]", name) log.debug("Shutting down ThreadBasedDispatcher [%s]", name)
active = false active = false
selectorThread.interrupt selectorThread.interrupt
references.clear references.clear