@Test
public void testAddSource() throws URISyntaxException, IOException {

  Source source = new MockSource();
  eventBus.post(new SourceAddedEvent(source));
  assertEquals("The source was not added to the pipeline",
      Collections.singletonList(source), pipeline.getSources());
}