Update ResponseFilter.java

telekom · Nov 14, 2024 · ecc8f85 · ecc8f85
1 parent 23693b7
commit ecc8f85
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/src/main/java/jumper/filter/ResponseFilter.java b/src/main/java/jumper/filter/ResponseFilter.java
@@ -45,9 +45,10 @@ public GatewayFilter apply(Config config) {
         (exchange, chain) ->
             chain
                 .filter(exchange)
-                .then(
-                    Mono.fromRunnable(
-                        () ->
+                .doOnTerminate(() -> {
+                        if (exchange.getResponse().isCommitted()) {
+                            return;
+                        }
                             WebFluxSleuthOperators.withSpanInScope(
                                 tracer,
                                 currentTraceContext,
@@ -90,7 +91,8 @@ public GatewayFilter apply(Config config) {
                                   }
 
                                   span.event("jrpf");
-                                }))),
+                                });
+                }),
         RequestFilter.REQUEST_FILTER_ORDER);
   }