@Test
public void forwardsMessagesToWrappedConsumer() throws Exception {

  connection = underTest.connect(recordingConsumer);
  connection.accept(14);
  recordingConsumer.assertValues("Value is: 14");
}