@Test
public void testMultipleConsumers() throws Exception
{

  DatabusCombinedConsumer logConsumer1 = new LoggingConsumer();
  DatabusCombinedConsumer logConsumer2 = new LoggingConsumer();
  List<DatabusCombinedConsumer> lcs = new ArrayList<DatabusCombinedConsumer>();
  lcs.add(logConsumer1);
  lcs.add(logConsumer2);
  List<String> sources = new ArrayList<String>();
  ConsumerRegistration consumerReg = new ConsumerRegistration(lcs, sources, null);
  DatabusStreamConsumer cons = consumerReg.getConsumer();
  boolean condition = logConsumer1.equals(cons) || logConsumer2.equals(cons);
  Assert.assertEquals(condition, true);
  return;
}