@Test
public void testRefocusForwarderThrottled() {

    ResultListSupplier responseSupplier = new ResultListSupplier(
            new ArrayList<StubResult>(),
            makeTooManyRequests(120),
            refocusForwarder);
    refocusForwarder.setStubSender(responseSupplier);
    int num_notifications = 5;
    History history = mock(History.class);
    enqueueSamples(num_notifications, history);
    waitUntilQueuedNotificationsAreProcessed(refocusForwarder);
    logForwarderStats();
    verifyProcessed(0, num_notifications, num_notifications);
}