@Override public Message receive() {
    Message message = delegate.receive();
    handleReceive(message);
    return message;
  }
@Test void receive_creates_consumer_span() throws Exception {
    ActiveMQTextMessage message = new ActiveMQTextMessage();
    receive(message);

    MutableSpan consumer = testSpanHandler.takeRemoteSpan(CONSUMER);
    assertThat(consumer.name()).isEqualTo("receive");
    assertThat(consumer.name()).isEqualTo("receive");
  }