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

fix - starter same method name invoke error

Browse Source
This commit is contained in:
wangli 2025-03-05 15:46:01 +08:00
parent 05d555d789
commit a41c6a950b
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

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