diff --git a/akka-actor-tests/src/test/scala/akka/actor/SupervisorHierarchySpec.scala b/akka-actor-tests/src/test/scala/akka/actor/SupervisorHierarchySpec.scala index 337bc81ba8..d818c85922 100644 --- a/akka-actor-tests/src/test/scala/akka/actor/SupervisorHierarchySpec.scala +++ b/akka-actor-tests/src/test/scala/akka/actor/SupervisorHierarchySpec.scala @@ -34,7 +34,7 @@ class SupervisorHierarchySpec extends JUnitSuite { val workerOne, workerTwo, workerThree = actorOf(Props(new CountDownActor(countDown)).withSupervisor(manager)) - workerOne ! Crash + workerOne ! Crash(new Exception("You suck!")) // manager + all workers should be restarted by only killing a worker // manager doesn't trap exits, so boss will restart manager diff --git a/akka-actor/src/main/scala/akka/dispatch/MailboxHandling.scala b/akka-actor/src/main/scala/akka/dispatch/MailboxHandling.scala index 89282909d8..fa3d542914 100644 --- a/akka-actor/src/main/scala/akka/dispatch/MailboxHandling.scala +++ b/akka-actor/src/main/scala/akka/dispatch/MailboxHandling.scala @@ -145,7 +145,7 @@ trait MailboxType { case class UnboundedMailbox() extends MailboxType { override def create(dispatcher: MessageDispatcher) = new NonblockingQueueMailbox(dispatcher) with UnboundedMessageQueueSemantics with DefaultSystemMessageImpl { - val queue = new ConcurrentLinkedQueue[Envelope]() + final val queue = new ConcurrentLinkedQueue[Envelope]() } } @@ -157,8 +157,8 @@ case class BoundedMailbox( if (pushTimeOut eq null) throw new IllegalArgumentException("The push time-out for BoundedMailbox can not be null") override def create(dispatcher: MessageDispatcher) = new BlockingQueueMailbox(dispatcher) with BoundedMessageQueueSemantics with DefaultSystemMessageImpl { - val queue = new LinkedBlockingQueue[Envelope](capacity) - val pushTimeOut = BoundedMailbox.this.pushTimeOut + final val queue = new LinkedBlockingQueue[Envelope](capacity) + final val pushTimeOut = BoundedMailbox.this.pushTimeOut } } @@ -177,8 +177,8 @@ case class BoundedPriorityMailbox( if (pushTimeOut eq null) throw new IllegalArgumentException("The push time-out for BoundedMailbox can not be null") override def create(dispatcher: MessageDispatcher) = new BlockingQueueMailbox(dispatcher) with BoundedMessageQueueSemantics with DefaultSystemMessageImpl { - val queue = new BoundedBlockingQueue[Envelope](capacity, new PriorityQueue[Envelope](11, cmp)) - val pushTimeOut = BoundedPriorityMailbox.this.pushTimeOut + final val queue = new BoundedBlockingQueue[Envelope](capacity, new PriorityQueue[Envelope](11, cmp)) + final val pushTimeOut = BoundedPriorityMailbox.this.pushTimeOut } }