Merge pull request #1 from doppleware/feature/observability

udpated
JNOSQL · Oct 16, 2023 · c2cd455 · c2cd455
2 parents cf7fa43 + 84727d7
commit c2cd455
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 0 deletions.
diff --git a/jnopo-talk/pom.xml b/jnopo-talk/pom.xml
@@ -31,7 +31,23 @@
         <jnosql.version>1.0.1</jnosql.version>
     </properties>
 
+    <dependencyManagement>
+        <dependencies>
+            <dependency>
+                <groupId>io.opentelemetry</groupId>
+                <artifactId>opentelemetry-bom</artifactId>
+                <version>1.10.0</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+
     <dependencies>
+        <dependency>
+            <groupId>io.opentelemetry</groupId>
+            <artifactId>opentelemetry-api</artifactId>
+        </dependency>
         <dependency>
             <groupId>jakarta.platform</groupId>
             <artifactId>jakarta.jakartaee-api</artifactId>
@@ -70,6 +86,11 @@
             <artifactId>jnosql-couchbase</artifactId>
             <version>${jnosql.version}</version>
         </dependency>
+        <dependency>
+            <groupId>io.opentelemetry.instrumentation</groupId>
+            <artifactId>opentelemetry-instrumentation-annotations</artifactId>
+            <version>1.26.0</version>
+        </dependency>
 
     </dependencies>
 

diff --git a/jnopo-talk/src/main/java/br/org/soujava/coffewithjava/jnopo/JNopoCatcher.java b/jnopo-talk/src/main/java/br/org/soujava/coffewithjava/jnopo/JNopoCatcher.java
@@ -1,6 +1,7 @@
 package br.org.soujava.coffewithjava.jnopo;
 
 import br.org.soujava.coffewithjava.jnopo.core.GameOver;
+import io.opentelemetry.instrumentation.annotations.WithSpan;
 import jakarta.ejb.Schedule;
 import jakarta.ejb.Singleton;
 import jakarta.ejb.Startup;
@@ -67,6 +68,7 @@ public void onError(Session session,
     }
 
     @OnMessage
+    @WithSpan
     public void onMessage(String message) {
         logger.info("Received the event >> %s".formatted(message));
         var event = jsonb.fromJson(message, GameEvent.class);
@@ -100,6 +102,7 @@ public void checkConnection() {
     @Database(DatabaseType.DOCUMENT)
     Playoffs playoffs;
 
+    @WithSpan
     private void save(GameEvent event) {
         var game = event.gameover();
         var match = new GameMatch(game.gameId(),