@Test
public void testSingleConsumer() throws Exception
{

  DatabusCombinedConsumer logConsumer = new LoggingConsumer();
  List<String> sources = new ArrayList<String>();
  ConsumerRegistration consumerReg = new ConsumerRegistration(logConsumer, sources, null);
  Assert.assertEquals(logConsumer, consumerReg.getConsumer());
  return;
}