diff --git a/iot-test-tool/iot-test-mqtt/src/main/java/cc/iotkit/test/mqtt/service/Device.java b/iot-test-tool/iot-test-mqtt/src/main/java/cc/iotkit/test/mqtt/service/Device.java index 3626cedd..d37f0763 100755 --- a/iot-test-tool/iot-test-mqtt/src/main/java/cc/iotkit/test/mqtt/service/Device.java +++ b/iot-test-tool/iot-test-mqtt/src/main/java/cc/iotkit/test/mqtt/service/Device.java @@ -20,7 +20,7 @@ public class Device { protected String productKey; -// private String productSecret ; + private String productSecret ; protected String deviceName; diff --git a/iot-test-tool/iot-test-mqtt/src/main/java/cc/iotkit/test/mqtt/service/MessageHandler.java b/iot-test-tool/iot-test-mqtt/src/main/java/cc/iotkit/test/mqtt/service/MessageHandler.java index 471257ae..391d077a 100755 --- a/iot-test-tool/iot-test-mqtt/src/main/java/cc/iotkit/test/mqtt/service/MessageHandler.java +++ b/iot-test-tool/iot-test-mqtt/src/main/java/cc/iotkit/test/mqtt/service/MessageHandler.java @@ -60,7 +60,7 @@ public class MessageHandler implements Handler { String productKey = data.get("productKey").toString(); String deviceName = data.get("deviceName").toString(); if (StringUtils.isBlank(productKey)) { - deviceOnlineListener.accept(new Device(productKey, deviceName, "")); + deviceOnlineListener.accept(new Device(productKey, "",deviceName, "")); return; } @@ -69,7 +69,7 @@ public class MessageHandler implements Handler { log.info("subscribe topic:{}", subTopic); client.subscribe(subTopic, 1, r -> { if (deviceOnlineListener != null) { - deviceOnlineListener.accept(new Device(productKey, deviceName, "")); + deviceOnlineListener.accept(new Device(productKey,"", deviceName, "")); } }); }