@Test
public void testStopAllConsumers() throws Exception {

    mockConnectionOperations();
    mockCheckingOperations();
    mockActivatingOperations();
    mockDeactivatingOperations();
    PowerMock.replayAll();
    consumerContainer.startAllConsumers();
    consumerContainer.stopAllConsumers();
    int disabledConsumerCount = consumerContainer.getDisabledConsumers().size();
    Assert.assertEquals(2, disabledConsumerCount);
    int inactiveConsumerCount = consumerContainer.getInactiveConsumers().size();
    Assert.assertEquals(2, inactiveConsumerCount);
    PowerMock.verifyAll();
}