@Test
public void requestTimeout_TimeoutMessage_schedulesTimeoutTask() {

    // given
    long timeoutInSec = 5;
    // when
    sut.requestTimeout(mockContext(), "anySagaId", timeoutInSec, TimeUnit.SECONDS, "anyName", null);
    // then
    ArgumentCaptor<SagaTimeoutTask> captor = ArgumentCaptor.forClass(SagaTimeoutTask.class);
    verify(executor).schedule(captor.capture(), eq(timeoutInSec), eq(TimeUnit.SECONDS));
    assertThat("Scheduled task not of expected type.", captor.getValue(), instanceOf(SagaTimeoutTask.class));
}