From 1e45bb750a1e7d2f16ff1cefd382cc7c65df4f13 Mon Sep 17 00:00:00 2001
From: wangli <274027703@qq.com>
Date: Fri, 14 Jun 2024 18:34:54 +0800
Subject: [PATCH] =?UTF-8?q?update(REQ-2516)=20-=20=E5=A2=9E=E5=8A=A0=20MQ?=
 =?UTF-8?q?=20=E7=9B=91=E6=8E=A7=E7=9A=84=EF=BC=8C=E5=8F=91=E7=8E=B0?=
 =?UTF-8?q?=E6=AD=BB=E4=BF=A1=E9=98=9F=E5=88=97=E7=9A=84=E9=92=A9=E5=AD=90?=
 =?UTF-8?q?=EF=BC=8C=E5=90=8C=E6=97=B6=EF=BC=8C=E4=B9=9F=E6=96=B0=E5=A2=9E?=
 =?UTF-8?q?=E5=8F=AF=E5=8A=A8=E6=80=81=E5=BC=80=E5=85=B3=E7=9B=91=E6=8E=A7?=
 =?UTF-8?q?=E7=9A=84=E7=AE=A1=E7=90=86=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../console/WorkflowEngineStarterMQMonitorController.java  | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/monitor/console/WorkflowEngineStarterMQMonitorController.java b/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/monitor/console/WorkflowEngineStarterMQMonitorController.java
index d1689bd5d..733e17039 100644
--- a/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/monitor/console/WorkflowEngineStarterMQMonitorController.java
+++ b/workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/monitor/console/WorkflowEngineStarterMQMonitorController.java
@@ -17,6 +17,7 @@ import org.springframework.web.bind.annotation.RestController;
 import javax.annotation.Resource;
 import java.util.HashMap;
 import java.util.Map;
+import java.util.Objects;
 
 import static cn.axzo.workflow.starter.StarterRPCInvokeMQConfiguration.DEFAULT_EVENT;
 import static cn.axzo.workflow.starter.common.constant.StarterConstants.MQ_GID_NAME_SEGMENT;
@@ -37,7 +38,7 @@ public class WorkflowEngineStarterMQMonitorController {
     @Resource
     private ObjectProvider<DefaultMQAdminExt> mqAdminExtObjectProvider;
     @Resource
-    private WorkflowEngineStarterDefaultMQMonitor monitor;
+    private ObjectProvider<WorkflowEngineStarterDefaultMQMonitor> monitorObjectProvider;
     @Resource
     private Environment environment;
     @Value("${spring.application.name}")
@@ -82,6 +83,10 @@ public class WorkflowEngineStarterMQMonitorController {
      */
     @GetMapping("/m/set")
     public CommonResponse<String> changeMonitorState(@RequestParam("status") Boolean status) {
+        WorkflowEngineStarterDefaultMQMonitor monitor = monitorObjectProvider.getIfAvailable();
+        if (Objects.isNull(monitor)) {
+            return CommonResponse.success("未开启·死信队列·的监控，如需，请设置 workflow.engine.starter.enableDlqMonitor = true 后再重试！");
+        }
         if (status) {
             if (!monitor.isRunning()) {
                 monitor.start();