- doNothing().when(mockCohort).startLogRecoveryBatch(any(int.class));
- doNothing().when(mockCohort).applyCurrentLogRecoveryBatch();
- doNothing().when(mockCohort).applyRecoverySnapshot(any(byte[].class));
- doNothing().when(mockCohort).appendRecoveredLogEntry(any(Payload.class));
- doReturn(null).when(mockCohort).getRestoreFromSnapshot();
- doReturn(true).when(mockPersistence).isRecoveryApplicable();
- doNothing().when(mockPersistence).deleteMessages(any(long.class));
- doNothing().when(mockPersistentProvider).deleteMessages(any(long.class));
- doNothing().when(mockPersistentProvider).deleteSnapshots(any(SnapshotSelectionCriteria.class));
- doNothing().when(mockPersistentProvider).persist(any(Object.class), any(Procedure.class));
-