Akka.Persistence.TCK.JournalSerializationSpec: made error messages in #…

…3964 clearer (#4008)
akkadotnet · Oct 28, 2019 · 73e9719 · 73e9719
1 parent 7966624
commit 73e9719
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/src/core/Akka.Persistence.TCK/Serialization/JournalSerializationSpec.cs b/src/core/Akka.Persistence.TCK/Serialization/JournalSerializationSpec.cs
@@ -101,10 +101,11 @@ public virtual void Journal_should_serialize_Persistent_with_EventAdapter_manife
             probe.ExpectMsg<WriteMessageSuccess>(m => m.ActorInstanceId == ActorInstanceId && m.Persistent.PersistenceId == Pid);
 
             Journal.Tell(new ReplayMessages(0, long.MaxValue, long.MaxValue, Pid, probe.Ref));
-            probe.ExpectMsg<ReplayedMessage>(s => s.Persistent.PersistenceId == persistentEvent.PersistenceId
-                                                  && s.Persistent.SequenceNr == persistentEvent.SequenceNr
-                                                  && s.Persistent.Payload.AsInstanceOf<TestJournal.MyPayload3>().Data.Equals(".item1.")
-                                                  && s.Persistent.Manifest == "First-Manifest");
+            var replayed = probe.ExpectMsg<ReplayedMessage>();
+            Assertions.AssertEqual(persistentEvent.PersistenceId, replayed.Persistent.PersistenceId);
+            Assertions.AssertEqual(persistentEvent.SequenceNr, replayed.Persistent.SequenceNr);
+            Assertions.AssertEqual(persistentEvent.Manifest, replayed.Persistent.Manifest);
+            Assertions.AssertEqual(".item1.", replayed.Persistent.Payload.AsInstanceOf<TestJournal.MyPayload3>().Data);
             probe.ExpectMsg<RecoverySuccess>();
         }