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

Merge pull request #19744 from akka/wip-19728-TCK-atomic-RK

Browse source 
do not require partial batch replay in TCK #19728
This commit is contained in:
Roland Kuhn 2016-02-11 13:32:56 +01:00
commit 4a4b19d86d
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala
View file

@ -124,12 +124,12 @@ abstract class JournalSpec(config: Config) extends PluginSpec(config) with MayVe
receiverProbe.expectMsg(RecoverySuccess(highestSequenceNr = 5L))
}
"replay messages using a lower and upper sequence number bound" in {
journal ! ReplayMessages(2, 4, Long.MaxValue, pid, receiverProbe.ref)
2 to 4 foreach { i ⇒ receiverProbe.expectMsg(replayedMessage(i)) }
journal ! ReplayMessages(2, 3, Long.MaxValue, pid, receiverProbe.ref)
2 to 3 foreach { i ⇒ receiverProbe.expectMsg(replayedMessage(i)) }
receiverProbe.expectMsg(RecoverySuccess(highestSequenceNr = 5L))
}
"replay messages using a lower and upper sequence number bound and a count limit" in {
journal ! ReplayMessages(2, 4, 2, pid, receiverProbe.ref)
journal ! ReplayMessages(2, 5, 2, pid, receiverProbe.ref)
2 to 3 foreach { i ⇒ receiverProbe.expectMsg(replayedMessage(i)) }
receiverProbe.expectMsg(RecoverySuccess(highestSequenceNr = 5L))
}