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 733e17039..1f3f1e523 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 @@ -57,21 +57,37 @@ public class WorkflowEngineStarterMQMonitorController { } else { mqAdminExtObjectProvider.ifAvailable(defaultMQAdminExt -> { String segment = environment.getProperty(MQ_GID_NAME_SEGMENT); + String broadcastConsumer = String.format(BROADCAST_CONSUMER_GROUP, applicationName, segment); + String rpcConsumer = String.format(RPC_RETRY_CONSUMER_GROUP, applicationName, segment); try { - String broadcastConsumer = String.format(BROADCAST_CONSUMER_GROUP, applicationName, segment); - String rpcConsumer = String.format(RPC_RETRY_CONSUMER_GROUP, applicationName, segment); result.put("Engine Broadcast MQ", defaultMQAdminExt.examineConsumeStats(broadcastConsumer)); + } catch (Exception e) { + log.warn("monitor controller examineConsumeStats broadcast error: {}", e.getMessage(), e); + } + try { result.put("Starter RPC MQ", defaultMQAdminExt.examineConsumeStats(rpcConsumer)); - + } catch (Exception e) { + log.warn("monitor controller examineConsumeStats rpc error: {}", e.getMessage(), e); + } // result.put("BrokerClusterInfo", defaultMQAdminExt.examineBrokerClusterInfo()); // result.put("TopicClusterList", defaultMQAdminExt.getTopicClusterList(topic)); + try { result.put("TopicRouteInfo", defaultMQAdminExt.examineTopicRouteInfo(topic)); + } catch (Exception e) { + log.warn("monitor controller examineTopicRouteInfo error: {}", e.getMessage(), e); + } // result.put("TopicStats", defaultMQAdminExt.examineTopicStats(topic)); + try { result.put("Broadcast-DLQ", defaultMQAdminExt.examineTopicStats(DLQ_PREFIX + broadcastConsumer)); + } catch (Exception e) { + log.warn("monitor controller examineTopicStats broadcast error: {}", e.getMessage(), e); + } + try { result.put("RPC-DLQ", defaultMQAdminExt.examineTopicStats(DLQ_PREFIX + rpcConsumer)); } catch (Exception e) { - log.warn("monitor controller error: {}", e.getMessage(), e); + log.warn("monitor controller examineTopicStats rpc error: {}", e.getMessage(), e); } + }); } return CommonResponse.success(result);