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() {