diff --git a/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/JetLinksApplication.java b/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/JetLinksApplication.java index b3bf0385..410a0ec2 100644 --- a/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/JetLinksApplication.java +++ b/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); } diff --git a/pom.xml b/pom.xml index 5c4df802..49a72552 100644 --- a/pom.xml +++ b/pom.xml @@ -270,6 +270,11 @@ test + + io.projectreactor + reactor-tools + + io.projectreactor reactor-test