From 6d4b857e109d60f18fdaf47c6b1de75cba804b85 Mon Sep 17 00:00:00 2001 From: wangli <274027703@qq.com> Date: Fri, 8 Nov 2024 10:04:15 +0800 Subject: [PATCH] =?UTF-8?q?fix=20-=20=E8=B0=83=E6=95=B4=E7=9B=91=E5=90=AC?= =?UTF-8?q?=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../workflow/server/mq/outside/DingtalkRocketConfiguration.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/outside/DingtalkRocketConfiguration.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/outside/DingtalkRocketConfiguration.java index 6b3f4591d..ae4b1383b 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/outside/DingtalkRocketConfiguration.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/outside/DingtalkRocketConfiguration.java @@ -61,7 +61,7 @@ public class DingtalkRocketConfiguration { @Component @ConditionalOnProperty(name = "rocketmq.name-server") @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, selectorType = SelectorType.TAG, selectorExpression = "riven-dingtalk-receive",