@SuppressWarnings("unchecked") @Test public void testPersistWithPersistenceEnabled() { doReturn(true).when(mockDelegateProvider).isRecoveryApplicable(); provider.persist(mockPersistentLogEntry, mockProcedure); verify(mockDelegateProvider).persist(mockPersistentLogEntry, mockProcedure); provider.persist(mockNonPersistentLogEntry, mockProcedure); verify(mockDelegateProvider).persist(mockNonPersistentLogEntry, mockProcedure); provider.persist(OTHER_DATA_OBJECT, mockProcedure); verify(mockDelegateProvider).persist(OTHER_DATA_OBJECT, mockProcedure); }
@Override public <T> void persist(final T entry, final Procedure<T> procedure) { doPersist(entry, procedure, false); }
RaftActorDelegatingPersistentDataProvider extends DelegatingPersistentDataProvider { @Override public <T> void persist(final T entry, final Procedure<T> procedure) { doPersist(entry, procedure, false); } }
RaftActorDelegatingPersistentDataProvider extends DelegatingPersistentDataProvider { @Override public <T> void persist(final T entry, final Procedure<T> procedure) { doPersist(entry, procedure, false); } RaftActorDelegatingPersistentDataProvider(final DataPersistenceProvider delegate,
            final PersistentDataProvider persistentProvider); }
RaftActorDelegatingPersistentDataProvider extends DelegatingPersistentDataProvider { @Override public <T> void persist(final T entry, final Procedure<T> procedure) { doPersist(entry, procedure, false); } RaftActorDelegatingPersistentDataProvider(final DataPersistenceProvider delegate,
            final PersistentDataProvider persistentProvider); @Override void persist(final T entry, final Procedure<T> procedure); @Override void persistAsync(final T entry, final Procedure<T> procedure); }
RaftActorDelegatingPersistentDataProvider extends DelegatingPersistentDataProvider { @Override public <T> void persist(final T entry, final Procedure<T> procedure) { doPersist(entry, procedure, false); } RaftActorDelegatingPersistentDataProvider(final DataPersistenceProvider delegate,
            final PersistentDataProvider persistentProvider); @Override void persist(final T entry, final Procedure<T> procedure); @Override void persistAsync(final T entry, final Procedure<T> procedure);  }