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

  Source source = new MockSource();
  eventBus.post(new SourceAddedEvent(source));
  eventBus.post(new SourceRemovedEvent(source));
  assertEquals("The source was not added then removed from the pipeline",
      Collections.emptyList(), pipeline.getSources());
}