raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Fix for race condition in WorkPullingWithEventSourcedProducerQueueSpec #29949

Browse source
This commit is contained in:
Johan Andrén 2021-01-19 13:36:40 +01:00
parent feec7aa9b1
commit 88ac481c68
1 changed files with 4 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-persistence-typed/src/test/scala/akka/persistence/typed/delivery/WorkPullingWithEventSourcedProducerQueueSpec.scala
View file

@ -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"