@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();
}