@Test
@SuppressWarnings("unchecked")
public void testAddConnection() {

  Connection connection = new MockConnection(eventBus, pipeline);
  eventBus.post(new ConnectionAddedEvent(connection));
  assertEquals("The connection was not added to the pipeline",
      Collections.singleton(connection), pipeline.getConnections());
}