- public void shouldSendMsgToDeadLetterWhenQueueIsFull() throws InterruptedException {
- final JavaTestKit mockReceiver = new JavaTestKit(actorSystem);
- actorSystem.eventStream().subscribe(mockReceiver.getRef(), DeadLetter.class);
+ public void shouldSendMsgToDeadLetterWhenQueueIsFull() {
+ final TestKit mockReceiver = new TestKit(actorSystem);
+ actorSystem.eventStream().subscribe(mockReceiver.testActor(), DeadLetter.class);