gitee/yudao-boot-mini
1
0
Fork 0
mirror of https://gitee.com/yudaocode/yudao-boot-mini.git synced 2026-03-22 05:27:15 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat：【IoT 物联网】新版本同步

Browse Source
This commit is contained in:
YunaiV
2025-08-30 11:31:23 +08:00
parent 0d70b4dd87
commit a3bbfe6cca
2 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
yudao-module-iot/yudao-module-iot-core/src/test/java/cn/iocoder/yudao/module/iot/core/messagebus/core/local/LocalIotMessageBusIntegrationTest.java
View File

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

10
yudao-module-iot/yudao-module-iot-core/src/test/java/cn/iocoder/yudao/module/iot/core/messagebus/core/rocketmq/RocketMQIotMessageBusTest.java
View File

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