From 88ac481c6833f6c450efe4a90024a0092d62019f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Tue, 19 Jan 2021 13:36:40 +0100 Subject: [PATCH] Fix for race condition in WorkPullingWithEventSourcedProducerQueueSpec #29949 --- .../WorkPullingWithEventSourcedProducerQueueSpec.scala | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/akka-persistence-typed/src/test/scala/akka/persistence/typed/delivery/WorkPullingWithEventSourcedProducerQueueSpec.scala b/akka-persistence-typed/src/test/scala/akka/persistence/typed/delivery/WorkPullingWithEventSourcedProducerQueueSpec.scala index ed6b058c21..cf35ffd1c4 100644 --- a/akka-persistence-typed/src/test/scala/akka/persistence/typed/delivery/WorkPullingWithEventSourcedProducerQueueSpec.scala +++ b/akka-persistence-typed/src/test/scala/akka/persistence/typed/delivery/WorkPullingWithEventSourcedProducerQueueSpec.scala @@ -93,17 +93,18 @@ class WorkPullingWithEventSourcedProducerQueueSpec producerProbe.expectNoMessage() val delivery1 = consumerProbe.receiveMessage() - delivery1.message should ===("a") delivery1.confirmTo ! ConsumerController.Confirmed val delivery2 = consumerProbe.receiveMessage() - delivery2.message should ===("b") delivery2.confirmTo ! ConsumerController.Confirmed val delivery3 = consumerProbe.receiveMessage() - delivery3.message should ===("c") delivery3.confirmTo ! ConsumerController.Confirmed + // since we have two consumers with the same probe order of delivery to the + // probe is not deterministic + Set(delivery1.message, delivery2.message, delivery3.message) should ===(Set("a", "b", "c")) + producerProbe.expectNoMessage() requestNext4.sendNextTo ! "d"