From db9abd60d8f86156374bb2a87988883deae90e79 Mon Sep 17 00:00:00 2001 From: chenwenjian Date: Mon, 12 Aug 2024 20:56:05 +0800 Subject: [PATCH] =?UTF-8?q?feat(REQ-2348):=20=E5=88=9B=E5=BB=BA=E6=96=BD?= =?UTF-8?q?=E5=B7=A5=E5=8C=BA=E5=9F=9F=E4=BA=8B=E4=BB=B6=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/axzo/nanopart/config/RocketMQEventConfiguration.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java b/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java index f8c33180..34757c62 100644 --- a/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java +++ b/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java @@ -183,7 +183,7 @@ public class RocketMQEventConfiguration { */ @Slf4j @Component - @RocketMQMessageListener(topic = "topic_construction_area_${spring.profiles.active]", + @RocketMQMessageListener(topic = "topic_construction_area_${spring.profiles.active}", consumerGroup = "GID_construction_area_${spring.application.name}_${spring.profiles.active}", consumeMode = ConsumeMode.ORDERLY, nameServer = "${rocketmq.name-server}")