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:48:34 +08:00
parent 80af410408
commit d4e4f4a45e
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

@ -165,6 +165,7 @@ public class StarterRPCInvokeMQConfiguration {
} }
@Component @Component
@ConditionalOnProperty(prefix = "rocketmq", value = "name-server")
@Conditional(NonContainerEnvironmentCondition.class) @Conditional(NonContainerEnvironmentCondition.class)
@RocketMQMessageListener(topic = DEFAULT_EVENT + "${spring.profiles.active}", @RocketMQMessageListener(topic = DEFAULT_EVENT + "${spring.profiles.active}",
consumerGroup = "GID_${spring.application.name}_workflow_engine_starter_${GID_SEGMENT}_consumer", consumerGroup = "GID_${spring.application.name}_workflow_engine_starter_${GID_SEGMENT}_consumer",
@ -199,6 +200,7 @@ public class StarterRPCInvokeMQConfiguration {
} }
@Bean("workflowEngineClientRetryEventListener") @Bean("workflowEngineClientRetryEventListener")
@ConditionalOnProperty(prefix = "rocketmq", value = "name-server")
public WorkflowEngineStarterRetryEventListener workflowEngineClientRetryEventListener(@Qualifier(WORKFLOW_ENGINE_STARTER_EVENT_CONSUMER_BEAN_NAME) EventConsumer workflowEngineStarterEventConsumer, public WorkflowEngineStarterRetryEventListener workflowEngineClientRetryEventListener(@Qualifier(WORKFLOW_ENGINE_STARTER_EVENT_CONSUMER_BEAN_NAME) EventConsumer workflowEngineStarterEventConsumer,
Environment environment, Environment environment,
WorkflowEngineStarterProperties starterProperties, WorkflowEngineStarterProperties starterProperties,