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

Incorrect assumption about event ordering in test fixed (#29411)

Browse source
This commit is contained in:
Johan Andrén 2020-07-22 12:19:03 +02:00 • committed by Christopher Batey
parent a563a9b69e
commit 165b39d1e0
1 changed files with 10 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

16
akka-persistence-typed-tests/src/test/scala/akka/persistence/typed/ActiveActiveSpec.scala
View file

@ -301,7 +301,7 @@ class ActiveActiveSpec
r1 ! StoreMe("from r1 2", probe.ref) r1 ! StoreMe("from r1 2", probe.ref)
probe.expectMessage(Done) probe.expectMessage(Done)
// r2 // r2, in order because we wrote them both in r1
eventProbeR2.expectMessage(EventAndContext("from r1 1", ReplicaId("R1"), false, false)) eventProbeR2.expectMessage(EventAndContext("from r1 1", ReplicaId("R1"), false, false))
eventProbeR2.expectMessage(EventAndContext("from r1 2", ReplicaId("R1"), false, false)) eventProbeR2.expectMessage(EventAndContext("from r1 2", ReplicaId("R1"), false, false))
@ -310,13 +310,17 @@ class ActiveActiveSpec
r2 ! StoreMe("from r2 2", probe.ref) r2 ! StoreMe("from r2 2", probe.ref)
probe.expectMessage(Done) probe.expectMessage(Done)
// r3 should only get the events 1, not R2s stored version of them // r3 should only get the events 1, not R2s stored version of them, but we don't know the
// order they will arrive
val eventProbeR3 = createTestProbe[EventAndContext]() val eventProbeR3 = createTestProbe[EventAndContext]()
spawn(testBehavior(entityId, "R3", eventProbeR3.ref)) spawn(testBehavior(entityId, "R3", eventProbeR3.ref))
eventProbeR3.expectMessage(EventAndContext("from r1 1", ReplicaId("R1"), false, false)) val eventAndContexts = eventProbeR3.receiveMessages(4).toSet
eventProbeR3.expectMessage(EventAndContext("from r1 2", ReplicaId("R1"), false, false)) eventAndContexts should ===(
eventProbeR3.expectMessage(EventAndContext("from r2 1", ReplicaId("R2"), false, false)) Set(
eventProbeR3.expectMessage(EventAndContext("from r2 2", ReplicaId("R2"), false, false)) EventAndContext("from r1 1", ReplicaId("R1"), false, false),
EventAndContext("from r1 2", ReplicaId("R1"), false, false),
EventAndContext("from r2 1", ReplicaId("R2"), false, false),
EventAndContext("from r2 2", ReplicaId("R2"), false, false)))
eventProbeR3.expectNoMessage() eventProbeR3.expectNoMessage()
} }