diff --git a/src/main/java/org/jetlinks/protocol/official/JetLinksProtocolSupportProvider.java b/src/main/java/org/jetlinks/protocol/official/JetLinksProtocolSupportProvider.java index 04997d9..496d604 100644 --- a/src/main/java/org/jetlinks/protocol/official/JetLinksProtocolSupportProvider.java +++ b/src/main/java/org/jetlinks/protocol/official/JetLinksProtocolSupportProvider.java @@ -66,14 +66,11 @@ public class JetLinksProtocolSupportProvider implements ProtocolSupportProvider JetLinksProtocolSupportProvider.class.getClassLoader()); support.addAuthenticator(DefaultTransport.MQTT, new JetLinksAuthenticator()); - support.addAuthenticator(DefaultTransport.MQTT_TLS, new JetLinksAuthenticator()); support.setMetadataCodec(new JetLinksDeviceMetadataCodec()); support.addConfigMetadata(DefaultTransport.MQTT, mqttConfig); - support.addConfigMetadata(DefaultTransport.MQTT_TLS, mqttConfig); support.addConfigMetadata(DefaultTransport.CoAP, coapConfig); - support.addConfigMetadata(DefaultTransport.CoAP_DTLS, coapDTLSConfig); support.addMessageCodecSupport(new JetLinksMqttDeviceMessageCodec(DefaultTransport.MQTT)); support.addMessageCodecSupport(new JetLinksMqttDeviceMessageCodec(DefaultTransport.MQTT_TLS)); diff --git a/src/main/java/org/jetlinks/protocol/official/TopicMessageCodec.java b/src/main/java/org/jetlinks/protocol/official/TopicMessageCodec.java index ccd3aec..a4ec3f4 100644 --- a/src/main/java/org/jetlinks/protocol/official/TopicMessageCodec.java +++ b/src/main/java/org/jetlinks/protocol/official/TopicMessageCodec.java @@ -262,9 +262,15 @@ public enum TopicMessageCodec { //断开连接回复 disconnectReply("/*/disconnect/reply", DisconnectDeviceMessageReply.class), //上线 - connect("/*/online", DeviceOnlineMessage.class), + connect("/*/online", DeviceOnlineMessage.class, builder -> builder + .upstream(true) + .group("状态管理") + .description("设备上线")), //离线 - offline("/*/offline", DeviceOfflineMessage.class), + offline("/*/offline", DeviceOfflineMessage.class, builder -> builder + .upstream(true) + .group("状态管理") + .description("设备离线")), //日志 log("/*/log", DeviceLogMessage.class), //状态检查