admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改dcc消费者

Browse Source
This commit is contained in:
zren25
2025-03-31 18:04:47 +08:00
parent b5595bc303
commit 51c539c25b
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
View File

@@ -25,8 +25,8 @@ import org.springframework.web.bind.annotation.RestController;
@Slf4j @Slf4j
@Component @Component
@RestController @RestController
@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopic}", @RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopicgroup}",
topic = "${rocketmq.consumer.corpus.dcctopicgroup}", topic = "${rocketmq.consumer.corpus.dcctopic}",
instanceName = "CorpusDccMqConsumer1", instanceName = "CorpusDccMqConsumer1",
enableMsgTrace = true) enableMsgTrace = true)
public class CorpusDccMqConsumer implements RocketMQListener<MessageExt> { public class CorpusDccMqConsumer implements RocketMQListener<MessageExt> {