wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update(REQ-2516) - 完善监控 Controller 类的逻辑

Browse Source
This commit is contained in:
wangli 2024-06-18 10:44:23 +08:00
parent 49ee53626f
commit 15dec8b8a5
1 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/mq/monitor/console/WorkflowEngineStarterMQMonitorController.java
View File

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