opensource/iboot
3
0
Fork 0
mirror of https://gitee.com/iteaj/iboot.git synced 2026-09-21 05:19:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

完善dtu调试

Browse Source
This commit is contained in:
fjcydl
2022-06-28 17:01:20 +08:00
parent 4bfafd5f93
commit 5b3101f896
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
bootstrap/src/main/java/com/iteaj/iboot/msn/iot/controller/DeviceDebugController.java
+2 -1
View File
@@ -5,6 +5,7 @@ import com.iteaj.framework.result.Result;
import com.iteaj.iboot.msn.iot.service.IDeviceService;
import com.iteaj.iot.client.mqtt.impl.DefaultMqttComponent;
import io.netty.handler.codec.mqtt.MqttQoS;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@@ -19,7 +20,7 @@ public class DeviceDebugController extends BaseController {
private final IDeviceService deviceService;
private final DefaultMqttComponent component;
public DeviceDebugController(DefaultMqttComponent component, IDeviceService deviceService) {
public DeviceDebugController(@Autowired(required = false) DefaultMqttComponent component, IDeviceService deviceService) {
this.component = component;
this.deviceService = deviceService;
}
bootstrap/src/main/java/com/iteaj/iboot/msn/iot/mqtt/MqttDebugSubscribeListener.java
+1 -1
View File
@@ -6,7 +6,7 @@ import io.netty.handler.codec.mqtt.MqttQoS;
import io.netty.handler.codec.mqtt.MqttTopicSubscription;
import org.springframework.stereotype.Component;
@Component
//@Component
public class MqttDebugSubscribeListener implements MqttSubscribeListener {
private MqttTopicSubscription subscription = new MqttTopicSubscription("iot/debug/#", MqttQoS.AT_MOST_ONCE);