From 59cdeca6ee56cb6e5d7cf08a938043618e3bc20b Mon Sep 17 00:00:00 2001
From: brunobat <brunobat@gmail.com>
Date: Fri, 12 Jul 2024 12:54:41 +0100
Subject: [PATCH] Add reactive messaging

---
 bom/application/pom.xml                                       | 2 +-
 .../io/quarkus/it/opentelemetry/OpenTelemetryTestCase.java    | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/bom/application/pom.xml b/bom/application/pom.xml
index d802f61b260f0d..04a05524d552af 100644
--- 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/integration-tests/opentelemetry-reactive-messaging/src/test/java/io/quarkus/it/opentelemetry/OpenTelemetryTestCase.java b/integration-tests/opentelemetry-reactive-messaging/src/test/java/io/quarkus/it/opentelemetry/OpenTelemetryTestCase.java
index a5bddafa393e1c..04c6c969321080 100644
--- a/integration-tests/opentelemetry-reactive-messaging/src/test/java/io/quarkus/it/opentelemetry/OpenTelemetryTestCase.java
+++ b/integration-tests/opentelemetry-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"));
     }