【同步】BOOT 和 CLOUD 的功能
This commit is contained in:
@@ -3,7 +3,7 @@ package cn.iocoder.yudao.module.iot.gateway.codec;
|
|||||||
import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
|
import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* {@link IotDeviceMessage} 的编解码器
|
* {@link cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage} 的编解码器
|
||||||
*
|
*
|
||||||
* @author 芋道源码
|
* @author 芋道源码
|
||||||
*/
|
*/
|
||||||
|
|||||||
@@ -123,7 +123,7 @@ public class IotMqttConnectionManager {
|
|||||||
* @param deviceId 设备 ID
|
* @param deviceId 设备 ID
|
||||||
* @return 连接信息
|
* @return 连接信息
|
||||||
*/
|
*/
|
||||||
public ConnectionInfo getConnectionInfoByDeviceId(Long deviceId) {
|
public IotMqttConnectionManager.ConnectionInfo getConnectionInfoByDeviceId(Long deviceId) {
|
||||||
// 通过设备 ID 获取连接端点
|
// 通过设备 ID 获取连接端点
|
||||||
MqttEndpoint endpoint = getDeviceEndpoint(deviceId);
|
MqttEndpoint endpoint = getDeviceEndpoint(deviceId);
|
||||||
if (endpoint == null) {
|
if (endpoint == null) {
|
||||||
|
|||||||
Reference in New Issue
Block a user