From b56d3a104b45bb5b1690cf4666817e8348aa7582 Mon Sep 17 00:00:00 2001 From: Prateek Gupta <76527682+prateekatknoldus@users.noreply.github.com> Date: Thu, 6 Jan 2022 19:36:55 +0530 Subject: [PATCH] fix the java example code for custom mailbox in akka-docs (#31034) --- .../src/test/java/jdocs/dispatcher/MyUnboundedMailbox.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-docs/src/test/java/jdocs/dispatcher/MyUnboundedMailbox.java b/akka-docs/src/test/java/jdocs/dispatcher/MyUnboundedMailbox.java index 9a07c5190e..90ed9b8bcb 100644 --- a/akka-docs/src/test/java/jdocs/dispatcher/MyUnboundedMailbox.java +++ b/akka-docs/src/test/java/jdocs/dispatcher/MyUnboundedMailbox.java @@ -41,8 +41,8 @@ public class MyUnboundedMailbox } public void cleanUp(ActorRef owner, MessageQueue deadLetters) { - for (Envelope handle : queue) { - deadLetters.enqueue(owner, handle); + while(!queue.isEmpty()) { + deadLetters.enqueue(owner, dequeue()); } } }