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:21:19 +08:00
parent 51c539c25b
commit ed185efc67
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -28,6 +28,7 @@ import org.springframework.web.bind.annotation.RestController;
@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopicgroup}", @RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopicgroup}",
topic = "${rocketmq.consumer.corpus.dcctopic}", topic = "${rocketmq.consumer.corpus.dcctopic}",
instanceName = "CorpusDccMqConsumer1", instanceName = "CorpusDccMqConsumer1",
consumeThreadNumber = 5, // 设置5个消费线程
enableMsgTrace = true) enableMsgTrace = true)
public class CorpusDccMqConsumer implements RocketMQListener<MessageExt> { public class CorpusDccMqConsumer implements RocketMQListener<MessageExt> {
@@ -40,6 +41,7 @@ public class CorpusDccMqConsumer implements RocketMQListener<MessageExt> {
public void onMessage(MessageExt messageExt) { public void onMessage(MessageExt messageExt) {
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
try { try {
log.info("corpusDccMqConsumer1 当前线程: {}, 线程ID: {}", Thread.currentThread().getName(), Thread.currentThread().getId());
String message = new String(messageExt.getBody()); String message = new String(messageExt.getBody());
log.info("dcc_mq message: " + message); log.info("dcc_mq message: " + message);
AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class); AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class);