Add reactive messaging

quarkusio · Jul 12, 2024 · 59cdeca · 59cdeca
1 parent ca4754f
commit 59cdeca
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/bom/application/pom.xml b/bom/application/pom.xml
@@ -62,7 +62,7 @@
         <smallrye-reactive-streams-operators.version>1.0.13</smallrye-reactive-streams-operators.version>
         <smallrye-reactive-types-converter.version>3.0.1</smallrye-reactive-types-converter.version>
         <smallrye-mutiny-vertx-binding.version>3.13.1</smallrye-mutiny-vertx-binding.version>
-        <smallrye-reactive-messaging.version>4.21.0</smallrye-reactive-messaging.version>
+        <smallrye-reactive-messaging.version>4.23.0</smallrye-reactive-messaging.version>
         <smallrye-stork.version>2.6.0</smallrye-stork.version>
         <jakarta.activation.version>2.1.3</jakarta.activation.version>
         <jakarta.annotation-api.version>3.0.0</jakarta.annotation-api.version>

diff --git a/...y-reactive-messaging/src/test/java/io/quarkus/it/opentelemetry/OpenTelemetryTestCase.java b/...y-reactive-messaging/src/test/java/io/quarkus/it/opentelemetry/OpenTelemetryTestCase.java
@@ -1,6 +1,6 @@
 package io.quarkus.it.opentelemetry;
 
-import static io.opentelemetry.instrumentation.api.instrumenter.messaging.MessageOperation.PUBLISH;
+import static io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessageOperation.PUBLISH;
 import static io.restassured.RestAssured.get;
 import static io.restassured.RestAssured.given;
 import static java.util.concurrent.TimeUnit.SECONDS;
@@ -163,7 +163,7 @@ private static void verifyConsumer(Map<String, Object> spanData,
         Assertions.assertEquals(topic, spanData.get("attr_messaging.destination.name"));
         Assertions.assertEquals("opentelemetry-integration-test", spanData.get("attr_messaging.kafka.consumer.group"));
         Assertions.assertEquals("0", spanData.get("attr_messaging.kafka.partition"));
-        Assertions.assertEquals("kafka-consumer-" + channel, spanData.get("attr_messaging.kafka.client_id"));
+        Assertions.assertEquals("kafka-consumer-" + channel, spanData.get("attr_messaging.client_id"));
         Assertions.assertEquals("0", spanData.get("attr_messaging.kafka.message.offset"));
     }