Merge pull request quarkusio#22615 from geoand/quarkusio#22597

Guard against CCE in OTel Vert.x integration
gsmet · Jan 4, 2022 · 077ea2f · 077ea2f
2 parents 6ffebe7 + ca59966
commit 077ea2f
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/...rc/main/java/io/quarkus/opentelemetry/runtime/tracing/vertx/OpenTelemetryVertxTracer.java b/...rc/main/java/io/quarkus/opentelemetry/runtime/tracing/vertx/OpenTelemetryVertxTracer.java
@@ -81,6 +81,10 @@ public <R> SpanOperation receiveRequest(
             final Iterable<Map.Entry<String, String>> headers,
             final TagExtractor<R> tagExtractor) {
 
+        if (!(request instanceof HttpRequest)) {
+            return null;
+        }
+
         io.opentelemetry.context.Context parentContext = context.getLocal(ACTIVE_CONTEXT);
         if (parentContext == null) {
             parentContext = io.opentelemetry.context.Context.root();
@@ -107,6 +111,10 @@ public <R> void sendResponse(
             return;
         }
 
+        if (!(response instanceof HttpResponse)) {
+            return;
+        }
+
         Scope scope = spanOperation.getScope();
         if (scope == null) {
             return;
@@ -130,6 +138,10 @@ public <R> SpanOperation sendRequest(
             final BiConsumer<String, String> headers,
             final TagExtractor<R> tagExtractor) {
 
+        if (!(request instanceof HttpRequest)) {
+            return null;
+        }
+
         io.opentelemetry.context.Context parentContext = context.getLocal(ACTIVE_CONTEXT);
         if (parentContext == null) {
             parentContext = io.opentelemetry.context.Context.root();
@@ -157,6 +169,10 @@ public <R> void receiveResponse(
             return;
         }
 
+        if (!(response instanceof HttpResponse)) {
+            return;
+        }
+
         Scope scope = spanOperation.getScope();
         if (scope == null) {
             return;