From 8d07c055ec7beca7b2048f8f802f8d3d2e4e3a78 Mon Sep 17 00:00:00 2001 From: Arnout Engelen Date: Mon, 26 Jul 2021 20:13:40 +0200 Subject: [PATCH] Fix race in RoutersTest (#30428) Refs #30424 --- .../java/akka/actor/typed/javadsl/RoutersTest.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/RoutersTest.java b/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/RoutersTest.java index 14cbe54c01..f1901f41ac 100644 --- a/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/RoutersTest.java +++ b/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/RoutersTest.java @@ -4,6 +4,8 @@ package akka.actor.typed.javadsl; +import java.util.List; + import akka.actor.testkit.typed.javadsl.LogCapturing; import akka.actor.testkit.typed.javadsl.TestKitJunitResource; import akka.actor.testkit.typed.javadsl.TestProbe; @@ -17,6 +19,7 @@ import org.junit.Test; import org.scalatestplus.junit.JUnitSuite; import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertTrue; public class RoutersTest extends JUnitSuite { @@ -55,10 +58,11 @@ public class RoutersTest extends JUnitSuite { String broadcastMsg = "bc-message"; pool.tell(broadcastMsg); - assertEquals(notBroadcastMsg, probe.receiveMessage()); + List messages = probe.receiveSeveralMessages(5); + assertTrue("non-broadcast message arrives", messages.contains(notBroadcastMsg)); - for (String msg : probe.receiveSeveralMessages(4)) { - assertEquals(broadcastMsg, msg); - } + int broadcast = 0; + for (String msg : messages) if (msg == broadcastMsg) broadcast++; + assertEquals("broadcast message arrives 4 times", broadcast, 4); } }