@Test
public void add_always_taskAddedToExecutor() {

    // given
    String message = "theMessage";
    // when
    sut.add(message);
    // then
    verify(executorService).execute(isA(SagaExecutionTask.class));
}