apm-agent-plugins/apm-jms-plugin/apm-jms-jakarta/src/main/java/co/elastic/apm/agent/jms/jakarta/JmsInstrumentationHelper.java [43:79]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class JmsInstrumentationHelper extends co.elastic.apm.agent.jms.JmsInstrumentationHelper<Destination, Message, MessageListener, JMSException> {

    private static final Logger logger = LoggerFactory.getLogger(JmsInstrumentationHelper.class);

    private static final JmsInstrumentationHelper INSTANCE = new JmsInstrumentationHelper(GlobalTracer.get());

    public static JmsInstrumentationHelper get() {
        return INSTANCE;
    }

    private JmsInstrumentationHelper(Tracer tracer) {
        super(tracer);
    }

    public static class MessageListenerWrapper implements MessageListener {

        private final MessageListener delegate;

        MessageListenerWrapper(MessageListener delegate) {
            this.delegate = delegate;
        }

        @Override
        public void onMessage(Message message) {
            delegate.onMessage(message);
        }
    }

    @Override
    public MessageListener newMessageListener(MessageListener listener) {
        return new MessageListenerWrapper(listener);
    }

    @Nullable
    public String extractDestinationName(@Nullable Message message, Destination destination) {
        String destinationName = null;
        if (message != null) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



apm-agent-plugins/apm-jms-plugin/apm-jms-javax/src/main/java/co/elastic/apm/agent/jms/javax/JmsInstrumentationHelper.java [41:77]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class JmsInstrumentationHelper extends co.elastic.apm.agent.jms.JmsInstrumentationHelper<Destination, Message, MessageListener, JMSException> {

    private static final Logger logger = LoggerFactory.getLogger(JmsInstrumentationHelper.class);

    private static final JmsInstrumentationHelper INSTANCE = new JmsInstrumentationHelper(GlobalTracer.get());

    public static JmsInstrumentationHelper get() {
        return INSTANCE;
    }

    private JmsInstrumentationHelper(Tracer tracer) {
        super(tracer);
    }

    public static class MessageListenerWrapper implements MessageListener {

        private final MessageListener delegate;

        MessageListenerWrapper(MessageListener delegate) {
            this.delegate = delegate;
        }

        @Override
        public void onMessage(Message message) {
            delegate.onMessage(message);
        }
    }

    @Override
    public MessageListener newMessageListener(MessageListener listener) {
        return new MessageListenerWrapper(listener);
    }

    @Nullable
    public String extractDestinationName(@Nullable Message message, Destination destination) {
        String destinationName = null;
        if (message != null) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -