@Test public void testOnSaveSnapshotFailure() { sendMessageToSupport(new SaveSnapshotFailure(new SnapshotMetadata("foo", 100, 1234L), new Throwable("mock"))); verify(mockSnapshotManager).rollback(); }
private void onSaveSnapshotFailure(SaveSnapshotFailure saveSnapshotFailure) { log.error("{}: SaveSnapshotFailure received for snapshot Cause:", context.getId(), saveSnapshotFailure.cause()); context.getSnapshotManager().rollback(); }
RaftActorSnapshotMessageSupport { private void onSaveSnapshotFailure(SaveSnapshotFailure saveSnapshotFailure) { log.error("{}: SaveSnapshotFailure received for snapshot Cause:", context.getId(), saveSnapshotFailure.cause()); context.getSnapshotManager().rollback(); } }
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); }
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);  }
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);   }