ConsumerContainer { protected List<ConsumerHolder> filterConsumersForEnabledFlag(boolean enabled) { List<ConsumerHolder> consumerHolderSubList = new LinkedList<ConsumerHolder>(); for (ConsumerHolder consumerHolder : consumerHolders) { if (consumerHolder.isEnabled() == enabled) { consumerHolderSubList.add(consumerHolder); } } return consumerHolderSubList; } ConsumerContainer(ConnectionFactory connectionFactory); void addConsumer(Consumer consumer, String queue); void addConsumer(Consumer consumer, String queue, boolean autoAck); void addConsumer(Consumer consumer, String queue, int prefetchMessageCount, int instances); void addConsumer(Consumer consumer, String queue, int instances); void addConsumer(Consumer consumer, String queue, boolean autoAck, int prefetchMessageCount, int instances); void addConsumer(Consumer consumer, String queue, boolean autoAck, int instances); synchronized void addConsumer(Consumer consumer, ConsumerConfiguration configuration, int instances); synchronized void startConsumers(Class<? extends Consumer> consumerClass); synchronized void startAllConsumers(); synchronized void stopConsumers(Class<? extends Consumer> consumerClass); synchronized void stopAllConsumers(); synchronized void reset(); List<ConsumerHolder> getEnabledConsumers(); List<ConsumerHolder> getDisabledConsumers(); List<ConsumerHolder> getActiveConsumers(); List<ConsumerHolder> getInactiveConsumers();  }
@Test public void testFilterConsumersForEnabledFlag() { List<ConsumerContainer.ConsumerHolder> consumerHolderList = consumerContainer.consumerHolders; consumerHolderList.get(0).enabled = true; consumerHolderList.get(1).enabled = false; int enabledInnerConsumerCount = consumerContainer.filterConsumersForEnabledFlag(true).size(); Assert.assertEquals(1, enabledInnerConsumerCount); int disabledInnerConsumerCount = consumerContainer.filterConsumersForEnabledFlag(false).size(); Assert.assertEquals(1, disabledInnerConsumerCount); }