From a3bbfe6ccaf76a36cbe780b6bea9f30cdae428c7 Mon Sep 17 00:00:00 2001
From: YunaiV <zhijiantianya@gmail.com>
Date: Sat, 30 Aug 2025 11:31:23 +0800
Subject: [PATCH] =?UTF-8?q?feat=EF=BC=9A=E3=80=90IoT=20=E7=89=A9=E8=81=94?=
 =?UTF-8?q?=E7=BD=91=E3=80=91=E6=96=B0=E7=89=88=E6=9C=AC=E5=90=8C=E6=AD=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../core/local/LocalIotMessageBusIntegrationTest.java  |  8 ++++----
 .../core/rocketmq/RocketMQIotMessageBusTest.java       | 10 +++++-----
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/yudao-module-iot/yudao-module-iot-core/src/test/java/cn/iocoder/yudao/module/iot/core/messagebus/core/local/LocalIotMessageBusIntegrationTest.java b/yudao-module-iot/yudao-module-iot-core/src/test/java/cn/iocoder/yudao/module/iot/core/messagebus/core/local/LocalIotMessageBusIntegrationTest.java
index fe658c5f58..72eb3a3281 100644
--- a/yudao-module-iot/yudao-module-iot-core/src/test/java/cn/iocoder/yudao/module/iot/core/messagebus/core/local/LocalIotMessageBusIntegrationTest.java
+++ b/yudao-module-iot/yudao-module-iot-core/src/test/java/cn/iocoder/yudao/module/iot/core/messagebus/core/local/LocalIotMessageBusIntegrationTest.java
@@ -48,7 +48,7 @@ public class LocalIotMessageBusIntegrationTest {
         AtomicInteger subscriber2Count = new AtomicInteger(0);
 
         // 创建第一个订阅者
-        IotMessageSubscriber<String> subscriber1 = new IotMessageSubscriber<>() {
+        IotMessageSubscriber<String> subscriber1 = new IotMessageSubscriber<String>() {
 
             @Override
             public String getTopic() {
@@ -70,7 +70,7 @@ public class LocalIotMessageBusIntegrationTest {
 
         };
         // 创建第二个订阅者
-        IotMessageSubscriber<String> subscriber2 = new IotMessageSubscriber<>() {
+        IotMessageSubscriber<String> subscriber2 = new IotMessageSubscriber<String>() {
 
             @Override
             public String getTopic() {
@@ -121,7 +121,7 @@ public class LocalIotMessageBusIntegrationTest {
         CountDownLatch latch = new CountDownLatch(2);
 
         // 创建订阅者 1 - 只订阅设备状态
-        IotMessageSubscriber<String> statusSubscriber = new IotMessageSubscriber<>() {
+        IotMessageSubscriber<String> statusSubscriber = new IotMessageSubscriber<String>() {
 
             @Override
             public String getTopic() {
@@ -142,7 +142,7 @@ public class LocalIotMessageBusIntegrationTest {
 
         };
         // 创建订阅者 2 - 只订阅设备数据
-        IotMessageSubscriber<String> dataSubscriber = new IotMessageSubscriber<>() {
+        IotMessageSubscriber<String> dataSubscriber = new IotMessageSubscriber<String>() {
 
             @Override
             public String getTopic() {
diff --git a/yudao-module-iot/yudao-module-iot-core/src/test/java/cn/iocoder/yudao/module/iot/core/messagebus/core/rocketmq/RocketMQIotMessageBusTest.java b/yudao-module-iot/yudao-module-iot-core/src/test/java/cn/iocoder/yudao/module/iot/core/messagebus/core/rocketmq/RocketMQIotMessageBusTest.java
index d3e5ced10b..e080c27c23 100644
--- a/yudao-module-iot/yudao-module-iot-core/src/test/java/cn/iocoder/yudao/module/iot/core/messagebus/core/rocketmq/RocketMQIotMessageBusTest.java
+++ b/yudao-module-iot/yudao-module-iot-core/src/test/java/cn/iocoder/yudao/module/iot/core/messagebus/core/rocketmq/RocketMQIotMessageBusTest.java
@@ -60,7 +60,7 @@ public class RocketMQIotMessageBusTest {
         messageBus.post(topic, testMessage);
 
         // 创建订阅者
-        IotMessageSubscriber<String> subscriber1 = new IotMessageSubscriber<>() {
+        IotMessageSubscriber<String> subscriber1 = new IotMessageSubscriber<String>() {
 
             @Override
             public String getTopic() {
@@ -118,7 +118,7 @@ public class RocketMQIotMessageBusTest {
         messageBus.post(topic, testMessage);
 
         // 创建第一个订阅者
-        IotMessageSubscriber<TestMessage> subscriber1 = new IotMessageSubscriber<>() {
+        IotMessageSubscriber<TestMessage> subscriber1 = new IotMessageSubscriber<TestMessage>() {
 
             @Override
             public String getTopic() {
@@ -142,7 +142,7 @@ public class RocketMQIotMessageBusTest {
 
         };
         // 创建第二个订阅者
-        IotMessageSubscriber<TestMessage> subscriber2 = new IotMessageSubscriber<>() {
+        IotMessageSubscriber<TestMessage> subscriber2 = new IotMessageSubscriber<TestMessage>() {
 
             @Override
             public String getTopic() {
@@ -205,7 +205,7 @@ public class RocketMQIotMessageBusTest {
         messageBus.post(topic2, message2);
 
         // 创建订阅者 1 - 只订阅设备状态
-        IotMessageSubscriber<String> statusSubscriber = new IotMessageSubscriber<>() {
+        IotMessageSubscriber<String> statusSubscriber = new IotMessageSubscriber<String>() {
 
             @Override
             public String getTopic() {
@@ -228,7 +228,7 @@ public class RocketMQIotMessageBusTest {
 
         };
         // 创建订阅者 2 - 只订阅设备数据
-        IotMessageSubscriber<String> dataSubscriber = new IotMessageSubscriber<>() {
+        IotMessageSubscriber<String> dataSubscriber = new IotMessageSubscriber<String>() {
 
             @Override
             public String getTopic() {