From 703997bd9bc292b9b090cc70b24a525d07ecf6d9 Mon Sep 17 00:00:00 2001 From: dongxiaodong <13970843+dxdwork@user.noreply.gitee.com> Date: Wed, 3 Apr 2024 10:42:30 +0800 Subject: [PATCH] =?UTF-8?q?dxd=E8=A7=A3=E6=9E=90=E6=8A=A5=E6=96=87?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/couplet/analyze/msg/model/ModelMessage.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelMessage.java b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelMessage.java index 201ff2a..c6c34ba 100644 --- a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelMessage.java +++ b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelMessage.java @@ -70,7 +70,7 @@ public class ModelMessage { for (CoupletMsgData msgData : coupletMsgDataList) { log.info("解析到车辆数据:{}", msgData); //发送日志到MQ - rabbitTemplate.convertAndSend("couplet-log-queue",msgData,message -> { + rabbitTemplate.convertAndSend("couplet-msg-queue",msgData,message -> { message.getMessageProperties().setMessageId(UUID.randomUUID().toString()); return message; });