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

fix - 调整监听配置

Browse Source
This commit is contained in:
wangli 2024-11-08 10:04:15 +08:00
parent 26bd236bb1
commit 6d4b857e10
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/outside/DingtalkRocketConfiguration.java
View File

@ -61,7 +61,7 @@ public class DingtalkRocketConfiguration {
@Component @Component
@ConditionalOnProperty(name = "rocketmq.name-server") @ConditionalOnProperty(name = "rocketmq.name-server")
@RocketMQMessageListener(topic = "topic_third_party_sync_event_${spring.profiles.active}", @RocketMQMessageListener(topic = "topic_third_party_sync_event_${spring.profiles.active}",
consumerGroup = "GID_${spring.application.name}_riven_consumer", consumerGroup = "GID_${spring.application.name}_riven_${spring.profiles.active}_consumer",
consumeMode = ConsumeMode.CONCURRENTLY, consumeMode = ConsumeMode.CONCURRENTLY,
selectorType = SelectorType.TAG, selectorType = SelectorType.TAG,
selectorExpression = "riven-dingtalk-receive", selectorExpression = "riven-dingtalk-receive",