@Test
public void testRetryAWSConnectivity() throws Throwable {

  final AtomicInteger counter = new AtomicInteger(0);
  invoker.retry("test", null, false,
      () -> {
        if (counter.incrementAndGet() < ACTIVE_RETRY_LIMIT) {
          throw CLIENT_TIMEOUT_EXCEPTION;
        }
      });
  assertEquals(ACTIVE_RETRY_LIMIT, counter.get());
}