@Test
public void testIntermittentInterruptedIOException() {

    // Assumes retries >= 3
    StubResult [] cycle = {
            makeWithInterruptedIOException(10, -1),
            makeWithInterruptedIOException(10, -1),
            make200(10, 1)
    };
    ResultCycleStubSupplier responseSupplier = new ResultCycleStubSupplier( cycle, refocusForwarder);
    refocusForwarder.setStubSender(responseSupplier);
    int num_notifications = 5;
    History history = mock(History.class);
    enqueueSamples(num_notifications, history);
    waitUntilQueuedNotificationsAreProcessed(refocusForwarder);
    logForwarderStats();
    verifyProcessed(num_notifications, 0, num_notifications);
}