From 8c8af4faa4303499fe9e81dd117932e246008eb0 Mon Sep 17 00:00:00 2001 From: aijinhui <aijinhui> Date: 星期六, 07 十月 2023 14:39:28 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java | 6 ++++++ 1 files changed, 6 insertions(+), 0 deletions(-) diff --git a/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java b/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java index 8504a14..62a2ca2 100644 --- a/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java +++ b/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java @@ -78,6 +78,12 @@ IStorageMinioEventService storageMinioEventService = SpringUtils.getBean(IStorageMinioEventService.class); storageMinioEventService.parseStorageMinioEvent(new String(message.getPayload(), StandardCharsets.UTF_8)); } + if (topic.equals("radarWellData")) + { + System.out.println(new String(message.getPayload(), StandardCharsets.UTF_8)); + IStorageMinioEventService storageMinioEventService = SpringUtils.getBean(IStorageMinioEventService.class); + storageMinioEventService.parseStorageMinioEvent(new String(message.getPayload(), StandardCharsets.UTF_8)); + } } catch (Exception e) { log.debug("澶勭悊mqtt娑堟伅寮傚父:" + e); } -- Gitblit v1.9.3