@Test
public void reset() throws Exception {

    dispatcher = new MessageDispatcher(sqsProxy, messageProcessorProxy);
    mockProcessorResults(messageResult("1", SQSMessageResult.Status.SUCCESS));
    dispatcher.dispatch(Lists.newArrayList(mockMessage("1")));
    assertThat(dispatcher.getEstimatedCapacity(NOW), is(not(Integer.MAX_VALUE)));
    dispatcher.reset();
    assertThat(dispatcher.getEstimatedCapacity(NOW), is(Integer.MAX_VALUE));
}