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

feat(REQ-2924) - 移除 starter 的 Bean 注册

Browse Source
This commit is contained in:
wangli 2024-09-13 23:36:33 +08:00
parent dbfc060791
commit 80af410408
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/StarterRPCInvokeMQConfiguration.java
View File

@ -139,6 +139,7 @@ public class StarterRPCInvokeMQConfiguration {
}
@Bean(WORKFLOW_ENGINE_STARTER_EVENT_HANDLER_REPOSITORY_BEAN_NAME)
@ConditionalOnProperty(prefix = "rocketmq", value = "name-server")
@ConditionalOnMissingBean(name = WORKFLOW_ENGINE_STARTER_EVENT_HANDLER_REPOSITORY_BEAN_NAME)
public EventHandlerRepository workflowEngineStarterEventHandlerRepository() {
return new EventHandlerRepository((ex, logText) -> {
@ -150,6 +151,7 @@ public class StarterRPCInvokeMQConfiguration {
}
@Bean(WORKFLOW_ENGINE_STARTER_EVENT_CONSUMER_BEAN_NAME)
@ConditionalOnProperty(prefix = "rocketmq", value = "name-server")
@ConditionalOnMissingBean(name = WORKFLOW_ENGINE_STARTER_EVENT_CONSUMER_BEAN_NAME)
public EventConsumer workflowEngineStarterEventConsumer(@Qualifier(WORKFLOW_ENGINE_STARTER_EVENT_HANDLER_REPOSITORY_BEAN_NAME) EventHandlerRepository workflowEngineStarterEventHandlerRepository) {
Consumer<EventConsumer.EventWrapper> callback = eventWrapper -> {