From 4c0b9110c9d0e077bbdace521252e5b96effdc9c Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Mon, 14 Feb 2011 02:51:26 +0100 Subject: [PATCH] Spellchecking and elided a try-block --- .../dispatch/ExecutorBasedEventDrivenDispatcher.scala | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/akka-actor/src/main/scala/akka/dispatch/ExecutorBasedEventDrivenDispatcher.scala b/akka-actor/src/main/scala/akka/dispatch/ExecutorBasedEventDrivenDispatcher.scala index 84f9d7b04c..2fa16eca71 100644 --- a/akka-actor/src/main/scala/akka/dispatch/ExecutorBasedEventDrivenDispatcher.scala +++ b/akka-actor/src/main/scala/akka/dispatch/ExecutorBasedEventDrivenDispatcher.scala @@ -163,7 +163,9 @@ trait ExecutableMailbox extends Runnable { self: MessageQueue => final def run = { try { - try { processMailbox() } catch { case ie: InterruptedException => true } + processMailbox() + } catch { + case ie: InterruptedException => } finally { dispatcherLock.unlock() } @@ -193,10 +195,10 @@ trait ExecutableMailbox extends Runnable { self: MessageQueue => if (self.suspended.locked) { null //If we are suspended, abort } - else { //If we aren't suspended, we need to make sure we're not overstepping our boundraries + else { //If we aren't suspended, we need to make sure we're not overstepping our boundaries processedMessages += 1 if ((processedMessages >= dispatcher.throughput) || (isDeadlineEnabled && System.nanoTime >= deadlineNs)) // If we're throttled, break out - null //We reached our boundraries, abort + null //We reached our boundaries, abort else self.dequeue //Dequeue the next message }