@Test
public void testAutoflushDisabled() {

  // buffer a request, with a mocked success
  underTest.add(createRequestEntry());
  verify(retryExecutorService, never())
      .schedule(any(Runnable.class), anyLong(), any(TimeUnit.class));
}