From 84b418d4b566c2269f4e0be18a8c3fdb828bcf57 Mon Sep 17 00:00:00 2001 From: Roland Kuhn Date: Wed, 10 Feb 2016 17:19:55 +0100 Subject: [PATCH] do not require partial batch replay in TCK #19728 --- .../main/scala/akka/persistence/journal/JournalSpec.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala b/akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala index 87b4eaf49d..863c4e4574 100644 --- a/akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala +++ b/akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala @@ -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)) }