From 5c1b6a5a377ce3f0db7bc36838b6d0273d8c45d0 Mon Sep 17 00:00:00 2001 From: wulin Date: Tue, 5 Dec 2023 14:00:40 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E9=9B=86=E6=88=90skywalking?= =?UTF-8?q?=E5=BC=95=E8=B5=B7=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/qiuguo/iot/user/api/filter/LogMdcConfiguration.java | 1 - .../qiuguo/iot/box/websocket/api/filter/LogMdcConfiguration.java | 1 - 2 files changed, 2 deletions(-) diff --git a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogMdcConfiguration.java b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogMdcConfiguration.java index edca2e6..b0aa053 100644 --- a/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogMdcConfiguration.java +++ b/iot-modules/iot-box-user-api/src/main/java/com/qiuguo/iot/user/api/filter/LogMdcConfiguration.java @@ -83,7 +83,6 @@ public class LogMdcConfiguration { WebFluxSkyWalkingOperators.continueTracing(ctx, () ->{ coreSubscriber.onNext(t); }); - coreSubscriber.onNext(t); } diff --git a/iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/filter/LogMdcConfiguration.java b/iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/filter/LogMdcConfiguration.java index d4c4f12..b7e2e46 100644 --- a/iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/filter/LogMdcConfiguration.java +++ b/iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/filter/LogMdcConfiguration.java @@ -75,7 +75,6 @@ public class LogMdcConfiguration { WebFluxSkyWalkingOperators.continueTracing(ctx, () ->{ coreSubscriber.onNext(t); }); - coreSubscriber.onNext(t); }