@Test
public final void testRunShouldSaveQueueSizesIntoQueueSizeProvider() throws Exception {

    // GIVEN
    Whitebox.setInternalState(underTest, "fIDecompressionEnabled", true);
    Whitebox.setInternalState(underTest, "messageWritingEnabled", true);
    QueueSizeProvider queueSizeProvider = new QueueSizeProvider();
    Whitebox.setInternalState(underTest, "queueSizeProvider", queueSizeProvider);
    given(mBeanServerConnection.getAttribute(responseQueue, "QueueSize")).willReturn(new Long(12));
    given(mBeanServerConnection.getAttribute(loggerQueue, "QueueSize")).willReturn(new Long(91));
    given(mBeanServerConnection.getAttribute(dlqQueue, "QueueSize")).willReturn(new Long(0));
    given(mBeanServerConnection.getAttribute(amqObject, "MemoryPercentUsage")).willReturn(new Integer(0));
    // WHEN
    underTest.run();
    // THEN
    long loggerQueueSize = ((QueueSizeProvider) Whitebox.getInternalState(underTest, "queueSizeProvider")).getLoggerQueueSize();
    Assert.assertEquals(loggerQueueSize, 91);
    long responseQueueSize = ((QueueSizeProvider) Whitebox.getInternalState(underTest, "queueSizeProvider")).getResponseQueueSize();
    Assert.assertEquals(responseQueueSize, 12);
}