RaftActorSnapshotMessageSupport { private void onSaveSnapshotFailure(SaveSnapshotFailure saveSnapshotFailure) { log.error("{}: SaveSnapshotFailure received for snapshot Cause:", context.getId(), saveSnapshotFailure.cause()); context.getSnapshotManager().rollback(); } RaftActorSnapshotMessageSupport(final RaftActorContext context, final RaftActorSnapshotCohort cohort);   }
@Test public void testOnSaveSnapshotFailure() { sendMessageToSupport(new SaveSnapshotFailure(new SnapshotMetadata("foo", 100, 1234L), new Throwable("mock"))); verify(mockSnapshotManager).rollback(); }