- assertEquals("Incorrect State after snapshot success is received ",
- Lists.newArrayList(payload0, payload1, payload2, payload3, payload4, payload5), singleNodeActorRef.underlyingActor().getState());
+ assertEquals("Incorrect State after snapshot success is received ", Lists.newArrayList(payload0, payload1,
+ payload2, payload3, payload4, payload5), singleNodeActorRef.underlyingActor().getState());
+
+ InMemoryJournal.waitForWriteMessagesComplete(persistenceId);