@Test
public void testStartAllConsumers() throws Exception {

    mockConnectionOperations();
    mockCheckingOperations();
    mockActivatingOperations();
    PowerMock.replayAll();
    consumerContainer.startAllConsumers();
    int enabledConsumerCount = consumerContainer.getEnabledConsumers().size();
    Assert.assertEquals(2, enabledConsumerCount);
    int activeConsumerCount = consumerContainer.getActiveConsumers().size();
    Assert.assertEquals(2, activeConsumerCount);
    PowerMock.verifyAll();
}