增加ReactorDebugAgent

jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/JetLinksApplication.java

@@ -13,6 +13,7 @@ import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.context.annotation.Profile;
 import org.springframework.context.event.EventListener;
 import org.springframework.stereotype.Component;
+import reactor.tools.agent.ReactorDebugAgent;
 
 import javax.annotation.PostConstruct;
 
@@ -27,6 +28,9 @@ import javax.annotation.PostConstruct;
 public class JetLinksApplication {
 
     public static void main(String[] args) {
+        if (!Boolean.getBoolean("reactor.debug.agent.disabled")) {
+            ReactorDebugAgent.init();
+        }
         SpringApplication.run(JetLinksApplication.class, args);
     }
 

pom.xml

@@ -270,6 +270,11 @@
             <scope>test</scope>
         </dependency>
 
+        <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-tools</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>io.projectreactor</groupId>
             <artifactId>reactor-test</artifactId>