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 2d4bf6dff..b10dd94b7 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 @@ -11,6 +11,7 @@ import org.apache.rocketmq.tools.admin.DefaultMQAdminExt; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.ObjectProvider; +import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.beans.factory.annotation.Value; import org.springframework.core.env.Environment; import org.springframework.web.bind.annotation.GetMapping; @@ -53,6 +54,9 @@ public class WorkflowEngineStarterMQMonitorController { private String applicationName; @Value("${spring.profiles.active}") private String activeProfile; + @Resource + @Qualifier("serviceVersion") + private String serviceVersion; public static String BROADCAST_CONSUMER_GROUP = "GID_%s_workflow_engine_%s_consumer"; public static String RPC_RETRY_CONSUMER_GROUP = "GID_%s_workflow_engine_starter_%s_consumer"; @@ -144,4 +148,9 @@ public class WorkflowEngineStarterMQMonitorController { return CommonResponse.success("以关闭 DLQ 钉钉通知"); } } + + @GetMapping("/v") + public CommonResponse consoleVersion() { + return CommonResponse.success("当前 workflow-engine version: " + serviceVersion + ",\r\nfix: cn.axzo.workflow.starter.mq.retry.consumer.WorkflowEngineStarterRetryEventListener.multiMethodCache"); + } }