five-groups
/
five-groups-couplet
4
0
Fork 0
Code Issues Pull Requests 2 Packages Projects Releases Wiki Activity

dxd解析报文

server_five_liuyunhu
dongxiaodong 2024-04-03 10:42:30 +08:00
parent 3947f9414e
commit 703997bd9b
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelMessage.java
View File

@ -70,7 +70,7 @@ public class ModelMessage {
for (CoupletMsgData msgData : coupletMsgDataList) { for (CoupletMsgData msgData : coupletMsgDataList) {
log.info("解析到车辆数据：{}", msgData); log.info("解析到车辆数据：{}", msgData);
//发送日志到MQ //发送日志到MQ
rabbitTemplate.convertAndSend("couplet-log-queue",msgData,message -> { rabbitTemplate.convertAndSend("couplet-msg-queue",msgData,message -> {
message.getMessageProperties().setMessageId(UUID.randomUUID().toString()); message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
return message; return message;
}); });