22
33This is a lightweight messaging wrappers API designed to help you quickly add instrumentation to any
44type of messaging system client. To further ease the burden of instrumentation, we will also provide
5- predefined implementations for certain messaging systems, helping you seamlessly address the issue
5+ predefined implementations for certain messaging systems, helping you seamlessly address the issue
66of broken traces.
77
88## Overview
99
10- The primary goal of this API is to simplify the process of adding instrumentation to your messaging
11- systems, thereby enhancing observability without introducing significant overhead. Inspired by
12- [ #13340 ] ( https://github.com/open-telemetry/opentelemetry-java-instrumentation/issues/13340 ) and
13- [ opentelemetry-java-instrumentation] ( https://github.com/open-telemetry/opentelemetry-java-instrumentation/blob/main/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/messaging/MessagingAttributesExtractor.java ) ,
10+ The primary goal of this API is to simplify the process of adding instrumentation to your messaging
11+ systems, thereby enhancing observability without introducing significant overhead. Inspired by
12+ [ #13340 ] ( https://github.com/open-telemetry/opentelemetry-java-instrumentation/issues/13340 ) and
13+ [ opentelemetry-java-instrumentation] ( https://github.com/open-telemetry/opentelemetry-java-instrumentation/blob/main/instrumentation-api-incubator/src/main/java/io/opentelemetry/instrumentation/api/incubator/semconv/messaging/MessagingAttributesExtractor.java ) ,
1414this tool aims to streamline the tracing and monitoring process.
1515
1616## Predefined Implementations
@@ -31,7 +31,7 @@ Gradle and Maven.
3131
3232``` kotlin
3333dependencies {
34- implementation(" io.opentelemetry.contrib:opentelemetry-messaging-wrappers-api" )
34+ implementation(" io.opentelemetry.contrib:opentelemetry-messaging-wrappers-api: ${latest_version} " )
3535}
3636```
3737
@@ -41,6 +41,7 @@ dependencies {
4141<dependency >
4242 <groupId >io.opentelemetry.contrib</groupId >
4343 <artifactId >opentelemetry-messaging-wrappers-api</artifactId >
44+ <version >${latest_version}</version >
4445</dependency >
4546```
4647
@@ -81,7 +82,7 @@ an implementation based on the OpenTelemetry semantic convention by default.
8182
8283``` java
8384public class KafkaDemo {
84-
85+
8586 public static MessagingProcessWrapper<KafkaProcessRequest > createWrapper () {
8687 return KafkaHelper . processWrapperBuilder(). build();
8788 }
@@ -98,9 +99,9 @@ If both are enabled, it might result in duplicate nested process spans. It is re
9899
99100``` java
100101public class Demo {
101-
102+
102103 private static final MessagingProcessWrapper<MyMessagingProcessRequest > WRAPPER = createWrapper();
103-
104+
104105 public String consume (Message message ) {
105106 WRAPPER . doProcess(new MyMessagingProcessRequest (message), () - > {
106107 // your processing logic
0 commit comments