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:49:27 +08:00
parent d4e4f4a45e
commit 2bff396e6b
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
workflow-engine-spring-boot-starter/src/main/java/cn/axzo/workflow/starter/StarterBroadcastMQConfiguration.java
View File

@ -57,6 +57,7 @@ public class StarterBroadcastMQConfiguration {
//================================= Workflow Engine Broadcast MQ =================================//
@Bean(BROADCAST_EVENT_HANDLER_REPOSITORY_BEAN_NAME)
@ConditionalOnProperty(prefix = "rocketmq", value = "name-server")
@ConditionalOnMissingBean(name = BROADCAST_EVENT_HANDLER_REPOSITORY_BEAN_NAME)
public EventHandlerRepository broadcastEventHandlerRepository() {
return new EventHandlerRepository((ex, logText) -> {
@ -69,6 +70,7 @@ public class StarterBroadcastMQConfiguration {
}
@Bean(BROADCAST_EVENT_CONSUMER_BEAN_NAME)
@ConditionalOnProperty(prefix = "rocketmq", value = "name-server")
@ConditionalOnMissingBean(name = BROADCAST_EVENT_CONSUMER_BEAN_NAME)
public EventConsumer broadcastEventConsumer(@Qualifier(BROADCAST_EVENT_HANDLER_REPOSITORY_BEAN_NAME) EventHandlerRepository eventHandlerRepository) {
Consumer<EventConsumer.EventWrapper> callback = eventWrapper -> {
@ -84,6 +86,7 @@ public class StarterBroadcastMQConfiguration {
}
@Component
@ConditionalOnProperty(prefix = "rocketmq", value = "name-server")
@Conditional(NonContainerEnvironmentCondition.class)
@RocketMQMessageListener(topic = DEFAULT_EVENT + "${spring.profiles.active}",
consumerGroup = "GID_${spring.application.name}_workflow_engine_${GID_SEGMENT}_consumer",
@ -125,6 +128,7 @@ public class StarterBroadcastMQConfiguration {
}
@Bean("workflowEngineBroadcastEventListener")
@ConditionalOnProperty(prefix = "rocketmq", value = "name-server")
public WorkflowEngineBroadcastEventListener workflowEngineBroadcastEventListener(@Qualifier(BROADCAST_EVENT_CONSUMER_BEAN_NAME) EventConsumer broadcastEventConsumer,
WorkflowEngineStarterProperties workflowEngineStarterProperties,
List<InnerWorkflowListener> listenerProvider) {