From 47de2dcaf37f12d76ab91f854c7ae0c4de5d83ea Mon Sep 17 00:00:00 2001 From: woodrow Date: Sat, 6 Jan 2024 14:45:52 +0800 Subject: [PATCH] =?UTF-8?q?fix=20=E8=87=AA=E5=AE=9A=E4=B9=89=E5=8D=8F?= =?UTF-8?q?=E8=AE=AE=E5=8C=85MQTT=E8=AE=A4=E8=AF=81=E8=A6=86=E5=86=99publi?= =?UTF-8?q?c=20Mono=20authenticate(@Nonnull=20Auth?= =?UTF-8?q?enticationRequest=20request,=20@Nonnull=20DeviceRegistry=20regi?= =?UTF-8?q?stry)=E4=B8=8D=E7=94=9F=E6=95=88=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mqtt/gateway/device/MqttServerDeviceGatewayProvider.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/gateway/device/MqttServerDeviceGatewayProvider.java b/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/gateway/device/MqttServerDeviceGatewayProvider.java index 6736e69a..62f55594 100755 --- a/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/gateway/device/MqttServerDeviceGatewayProvider.java +++ b/jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/gateway/device/MqttServerDeviceGatewayProvider.java @@ -78,7 +78,7 @@ public class MqttServerDeviceGatewayProvider implements DeviceGatewayProvider { sessionManager, mqttServer, messageHandler, - Mono.empty() + protocolSupports.getProtocol(properties.getProtocol()) )); } -- Gitee