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 6736e69ac119aff642af97fbdd6fbfccb960d70d..62f55594c20d5f628d6901fe70727df30dc6dd10 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())
             ));
     }