@Test
public void testStartConsumerCreateThrowsException() throws Exception {

  doThrow(new RuntimeException("Expected")).when(source).createConsumer();
  source.configure(context);
  source.start();
  try {
    source.process();
    Assert.fail();
  } catch (FlumeException expected) {
  }
}