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 ffb955d43e..cbde1567fc 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 @@ -262,9 +262,10 @@ abstract class JournalSpec(config: Config) extends PluginSpec(config) with MayVe receiverProbe.expectMsgPF() { case ReplayedMessage(PersistentImpl(payload, 6L, Pid, _, _, Actor.noSender, WriterUuid)) ⇒ payload should be(event) } - receiverProbe.expectMsg(RecoverySuccess(highestSequenceNr = 6L)) + receiverProbe.expectMsgPF() { + case RecoverySuccess(highestSequenceNr) ⇒ highestSequenceNr should be >= 6L + } } } - } }