@Test
public void delegatesDisposeToActualConnection() throws Exception {

  connection = underTest.connect(recordingConsumer);
  connection.dispose();
  assertThat(testConnection.disposed, is(true));
}