final static long OTHER_OFFSET = 1;
final static Instant NOW = Instant.now();
+ @Mock Clock clock;
+ @Mock BackOff backOff;
+ @Mock BackOffExecution backOffExecution;
+
private BackOffState NotStartedBackOffState()
{
}
- private BackOffState StartedBackoffStateWithNoRetries(
- Clock clock,
- BackOff backOff,
- BackOffExecution backOffExecution)
+ private BackOffState StartedBackoffStateWithNoRetries()
{
given(clock.instant()).willReturn(NOW);
given(backOff.start()).willReturn(backOffExecution);
@Test
@DisplayName("A started BackOffState with no retries is not waiting for a retry")
- void StartedBackOffStateWithNoRetriesIsNotWaitingForRetry(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateWithNoRetriesIsNotWaitingForRetry()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithNoRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithNoRetries();
// WHEN
@Test
@DisplayName("A started BackOffState with no retries is started")
- void StartedBackOffStateWithNoRetriesIsStarted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateWithNoRetriesIsStarted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithNoRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithNoRetries();
// WHEN
@Test
@DisplayName("A started BackOffState with no retries is completed")
- void StartedBackOffStateWithNoRetriesIsCompleted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateWithNoRetriesIsCompleted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithNoRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithNoRetries();
// WHEN
}
- private BackOffState StartedBackoffStateWithRetries(
- Clock clock,
- BackOff backOff,
- BackOffExecution backOffExecution)
+ private BackOffState StartedBackoffStateWithRetries()
{
given(clock.instant()).willReturn(NOW);
given(backOff.start()).willReturn(backOffExecution);
@Test
@DisplayName("A started BackOffState is waiting for a retry if the time is not due")
- void StartedBackOffStateIsWaitingForRetryIfTimeIsNotDue(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsWaitingForRetryIfTimeIsNotDue()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
given(clock.instant()).willReturn(NOW.plusMillis(1000));
// WHEN
@Test
@DisplayName("A started BackOffState is started if the time is not due")
- void StartedBackOffStateIsStarted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsStarted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
given(clock.instant()).willReturn(NOW.plusMillis(1000));
// WHEN
@Test
@DisplayName("A started BackOffState is not started for other offsets if the time is not due")
- void StartedBackOffStateIsNotStartedForOtherOffsetsIfTheTimeIsNotDue(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsNotStartedForOtherOffsetsIfTheTimeIsNotDue()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
given(clock.instant()).willReturn(NOW.plusMillis(1000));
// WHEN
@Test
@DisplayName("A started BackOffState is not completed if the time is not due")
- void StartedBackOffStateIsNotCompletedIfTimeIsNotDue(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsNotCompletedIfTimeIsNotDue()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
given(clock.instant()).willReturn(NOW.plusMillis(1000));
// WHEN
@Test
@DisplayName("A started BackOffState is not waiting for a retry if the time is due but the retry not yet completed")
- void StartedBackOffStateIsNotWaitingForRetryIfTheTimeIsDueButRetryNotCompleted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsNotWaitingForRetryIfTheTimeIsDueButRetryNotCompleted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
given(clock.instant()).willReturn(NOW.plusMillis(1001));
given(backOffExecution.nextBackOff()).willReturn(1000l);
@Test
@DisplayName("A started BackOffState is started if the time is due but the retry not yet completed")
- void StartedBackOffStateIsStartedIfTheTimeIsDueButRetryNotCompleted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsStartedIfTheTimeIsDueButRetryNotCompleted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
given(clock.instant()).willReturn(NOW.plusMillis(1001));
given(backOffExecution.nextBackOff()).willReturn(1000l);
@Test
@DisplayName("A started BackOffState is not started for other offsets if the time is due but the retry not yet completed")
- void StartedBackOffStateIsNotStartedForOtherOffsetsIfTheTimeIsDueButRetryNotCompleted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsNotStartedForOtherOffsetsIfTheTimeIsDueButRetryNotCompleted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
given(clock.instant()).willReturn(NOW.plusMillis(1001));
given(backOffExecution.nextBackOff()).willReturn(1000l);
@Test
@DisplayName("A started BackOffState is not completed if the time is due but the retry not yet completed")
- void StartedBackOffStateIsNotCompletedIfTheTimeIsDueButRetryNotCompleted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsNotCompletedIfTheTimeIsDueButRetryNotCompleted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
given(clock.instant()).willReturn(NOW.plusMillis(1001));
given(backOffExecution.nextBackOff()).willReturn(1000l);
@Test
@DisplayName("A started BackOffState is not waiting for a retry if the time is due and the retry is completed")
- void StartedBackOffStateIsNotWaitingForRetryIfTheTimeIsDueAndRetryIsCompleted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsNotWaitingForRetryIfTheTimeIsDueAndRetryIsCompleted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
given(clock.instant()).willReturn(NOW.plusMillis(1001));
given(backOffExecution.nextBackOff()).willReturn(BackOffExecution.STOP);
@Test
@DisplayName("A started BackOffState is started if the time is due and the retry is completed")
- void StartedBackOffStateIsStartedIfTheTimeIsDueAndRetryIsCompleted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsStartedIfTheTimeIsDueAndRetryIsCompleted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
given(clock.instant()).willReturn(NOW.plusMillis(1001));
given(backOffExecution.nextBackOff()).willReturn(BackOffExecution.STOP);
@Test
@DisplayName("A started BackOffState is not started for other offsets if the time is due and the retry is completed")
- void StartedBackOffStateIsNotStartedForOtherOffsetsIfTheTimeIsDueAndRetryIsCompleted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsNotStartedForOtherOffsetsIfTheTimeIsDueAndRetryIsCompleted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
given(clock.instant()).willReturn(NOW.plusMillis(1001));
given(backOffExecution.nextBackOff()).willReturn(BackOffExecution.STOP);
@Test
@DisplayName("A started BackOffState is completed if the time is due and the retry is completed")
- void StartedBackOffStateIsCompletedIfTheTimeIsDueAndRetryIsCompleted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsCompletedIfTheTimeIsDueAndRetryIsCompleted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
given(clock.instant()).willReturn(NOW.plusMillis(1001));
given(backOffExecution.nextBackOff()).willReturn(BackOffExecution.STOP);
@Test
@DisplayName("A started BackOffState is not waiting for a retry if it is marked as completed")
- void StartedBackOffStateIsNotWaitingForRetryIfMarkedCompleted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsNotWaitingForRetryIfMarkedCompleted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
// WHEN
backOffState.markAsCompleted();
@Test
@DisplayName("A started BackOffState is not started if it is marked as completed")
- void StartedBackOffStateIsNotStartedIfMarkedCompleted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsNotStartedIfMarkedCompleted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
// WHEN
backOffState.markAsCompleted();
@Test
@DisplayName("A started BackOffState is not started for other offsets if it is marked as completed")
- void StartedBackOffStateIsNotStartedForOtherOffsetsIfMarkedCompleted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsNotStartedForOtherOffsetsIfMarkedCompleted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
// WHEN
backOffState.markAsCompleted();
@Test
@DisplayName("A started BackOffState is not completed if it is marked as completed")
- void StartedBackOffStateIsNotCompletedIfMarkedCompleted(
- @Mock Clock clock,
- @Mock BackOff backOff,
- @Mock BackOffExecution backOffExecution)
+ void StartedBackOffStateIsNotCompletedIfMarkedCompleted()
{
// GIVEN
- BackOffState backOffState = StartedBackoffStateWithRetries(clock, backOff, backOffExecution);
+ BackOffState backOffState = StartedBackoffStateWithRetries();
// WHEN
backOffState.markAsCompleted();