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 }