@Test public void testSuccessfulActionsPassThrough() throws Exception { retryInterceptor.apply(SampleTitusChangeActions.successfulJob()).apply().subscribe(testSubscriber); List<ModelActionHolder> updateAction = testSubscriber.takeNext(); assertThat(updateAction.get(0).getAction()).isInstanceOf(RetryActionInterceptor.RemoveRetryRecord.class); testSubscriber.assertOnCompleted(); }
@Override public TitusChangeAction apply(TitusChangeAction changeAction) { return new RetryChangeAction(changeAction); }
RetryActionInterceptor implements TitusChangeActionInterceptor<Boolean> { @Override public TitusChangeAction apply(TitusChangeAction changeAction) { return new RetryChangeAction(changeAction); } }
RetryActionInterceptor implements TitusChangeActionInterceptor<Boolean> { @Override public TitusChangeAction apply(TitusChangeAction changeAction) { return new RetryChangeAction(changeAction); } RetryActionInterceptor(String name,
                                  Retryer initialRetryPolicy,
                                  Scheduler scheduler); }
RetryActionInterceptor implements TitusChangeActionInterceptor<Boolean> { @Override public TitusChangeAction apply(TitusChangeAction changeAction) { return new RetryChangeAction(changeAction); } RetryActionInterceptor(String name,
                                  Retryer initialRetryPolicy,
                                  Scheduler scheduler); @Override TitusChangeAction apply(TitusChangeAction changeAction); @Override Boolean executionLimits(EntityHolder rootHolder); }
RetryActionInterceptor implements TitusChangeActionInterceptor<Boolean> { @Override public TitusChangeAction apply(TitusChangeAction changeAction) { return new RetryChangeAction(changeAction); } RetryActionInterceptor(String name,
                                  Retryer initialRetryPolicy,
                                  Scheduler scheduler); @Override TitusChangeAction apply(TitusChangeAction changeAction); @Override Boolean executionLimits(EntityHolder rootHolder);  }