@Test
public void testStartConsumers() throws Exception {

    mockConnectionOperations();
    mockCheckingOperations();
    mockActivatingOperations();
    PowerMock.replayAll();
    consumerContainer.startConsumers(TestConsumerOne.class);
    int enabledConsumerCount = consumerContainer.getEnabledConsumers().size();
    Assert.assertEquals(1, enabledConsumerCount);
    consumerContainer.startConsumers(TestConsumerTwo.class);
    enabledConsumerCount = consumerContainer.getEnabledConsumers().size();
    Assert.assertEquals(2, enabledConsumerCount);
}