Skip to content

Commit bacd3d3

Browse files
committed
Make Process messages as link in case of stable messaging
1 parent 1cf86e5 commit bacd3d3

File tree

2 files changed

+8
-2
lines changed
  • instrumentation/jms
    • jms-1.1/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/jms/v1_1
    • jms-3.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/jms/v3_0

2 files changed

+8
-2
lines changed

instrumentation/jms/jms-1.1/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/jms/v1_1/JmsSingletons.java

+4-1
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,8 @@
55

66
package io.opentelemetry.javaagent.instrumentation.jms.v1_1;
77

8+
import static io.opentelemetry.instrumentation.api.internal.SemconvStability.emitStableMessagingSemconv;
9+
810
import io.opentelemetry.api.GlobalOpenTelemetry;
911
import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
1012
import io.opentelemetry.javaagent.bootstrap.internal.ExperimentalConfig;
@@ -27,7 +29,8 @@ public final class JmsSingletons {
2729

2830
PRODUCER_INSTRUMENTER = factory.createProducerInstrumenter();
2931
CONSUMER_RECEIVE_INSTRUMENTER = factory.createConsumerReceiveInstrumenter();
30-
CONSUMER_PROCESS_INSTRUMENTER = factory.createConsumerProcessInstrumenter(false);
32+
CONSUMER_PROCESS_INSTRUMENTER =
33+
factory.createConsumerProcessInstrumenter(emitStableMessagingSemconv());
3134
}
3235

3336
public static Instrumenter<MessageWithDestination, Void> producerInstrumenter() {

instrumentation/jms/jms-3.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/jms/v3_0/JmsSingletons.java

+4-1
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,8 @@
55

66
package io.opentelemetry.javaagent.instrumentation.jms.v3_0;
77

8+
import static io.opentelemetry.instrumentation.api.internal.SemconvStability.emitStableMessagingSemconv;
9+
810
import io.opentelemetry.api.GlobalOpenTelemetry;
911
import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
1012
import io.opentelemetry.javaagent.bootstrap.internal.ExperimentalConfig;
@@ -27,7 +29,8 @@ public final class JmsSingletons {
2729

2830
PRODUCER_INSTRUMENTER = factory.createProducerInstrumenter();
2931
CONSUMER_RECEIVE_INSTRUMENTER = factory.createConsumerReceiveInstrumenter();
30-
CONSUMER_PROCESS_INSTRUMENTER = factory.createConsumerProcessInstrumenter(false);
32+
CONSUMER_PROCESS_INSTRUMENTER =
33+
factory.createConsumerProcessInstrumenter(emitStableMessagingSemconv());
3134
}
3235

3336
public static Instrumenter<MessageWithDestination, Void> producerInstrumenter() {

0 commit comments

Comments
 (0)