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

Improve InmemPersistentActorSpec stability

Browse source 
Intended to improve #30498
This commit is contained in:
Arnout Engelen 2021-08-16 15:25:01 +02:00
parent 999b0853d5
commit c2bd4c196a
No known key found for this signature in database
GPG key ID: 061107B0F74A6DAA
1 changed files with 19 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

32
akka-persistence/src/test/scala/akka/persistence/PersistentActorSpec.scala
View file

@ -1214,13 +1214,14 @@ abstract class PersistentActorSpec(config: Config) extends PersistenceSpec(confi
// that commands are processed before events have been persisted. Therefore, we
// retry until eventually...
eventually {
val probe = TestProbe()
val persistentActor = asyncPersistPersistentActor
persistentActor ! Cmd("x")
persistentActor ! Cmd("y")
expectMsg("x")
expectMsg("y") // "y" command was processed before event persisted
expectMsg("x-1")
expectMsg("y-2")
probe.send(persistentActor, Cmd("x"))
probe.send(persistentActor, Cmd("y"))
probe.expectMsg("x")
probe.expectMsg("y") // "y" command was processed before event persisted
probe.expectMsg("x-1")
probe.expectMsg("y-2")
}
}
"support multiple persistAsync calls for one command, and execute them 'when possible', not hindering command processing" in {
@ -1424,13 +1425,18 @@ abstract class PersistentActorSpec(config: Config) extends PersistenceSpec(confi
test(deferringSyncWithAsyncPersistActor)
}
"handle new messages before deferAsync handler is called" in {
val persistentActor = deferringAsyncActor
persistentActor ! Cmd("x")
persistentActor ! Cmd("y")
expectMsg("x")
expectMsg("y") // "y" command was processed before event persisted
expectMsg("x-defer")
expectMsg("y-defer")
// Depending on timing, 'x-defer' might arrive before or after 'y'.
// This test is meant to demonstrate that 'x-defer' *may* arrive later.'
eventually {
val probe = TestProbe()
val persistentActor = deferringAsyncActor
probe.send(persistentActor, Cmd("x"))
probe.send(persistentActor, Cmd("y"))
probe.expectMsg("x")
probe.expectMsg("y") // "y" command was processed before event persisted
probe.expectMsg("x-defer")
probe.expectMsg("y-defer")
}
}
"handle defer sequentially" in {
val persistentActor = deferringSyncActor