From 51c539c25ba56fc7344eeca4165ce5075751ce84 Mon Sep 17 00:00:00 2001 From: zren25 Date: Mon, 31 Mar 2025 18:04:47 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9dcc=E6=B6=88=E8=B4=B9?= =?UTF-8?q?=E8=80=85?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java index 46ab7e5..9a8059a 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java @@ -25,8 +25,8 @@ import org.springframework.web.bind.annotation.RestController; @Slf4j @Component @RestController -@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopic}", - topic = "${rocketmq.consumer.corpus.dcctopicgroup}", +@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopicgroup}", + topic = "${rocketmq.consumer.corpus.dcctopic}", instanceName = "CorpusDccMqConsumer1", enableMsgTrace = true) public class CorpusDccMqConsumer implements RocketMQListener {