RaftActorSnapshotMessageSupport { private void onSaveSnapshotSuccess(SaveSnapshotSuccess success) { long sequenceNumber = success.metadata().sequenceNr(); log.info("{}: SaveSnapshotSuccess received for snapshot, sequenceNr: {}", context.getId(), sequenceNumber); context.getSnapshotManager().commit(sequenceNumber, success.metadata().timestamp()); } RaftActorSnapshotMessageSupport(final RaftActorContext context, final RaftActorSnapshotCohort cohort);   }
@Test public void testOnSaveSnapshotSuccess() { long sequenceNumber = 100; long timeStamp = 1234L; sendMessageToSupport(new SaveSnapshotSuccess(new SnapshotMetadata("foo", sequenceNumber, timeStamp))); verify(mockSnapshotManager).commit(eq(sequenceNumber), eq(timeStamp)); }