yuanbiao
/
jetlinks-official-protocol
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

优化

This commit is contained in:
zhouhao 2022-06-20 17:33:07 +08:00
parent 8de80583f6
commit 8e0faae4db
2 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/jetlinks/protocol/official/JetLinksProtocolSupportProvider.java
View File

@ -66,14 +66,11 @@ public class JetLinksProtocolSupportProvider implements ProtocolSupportProvider
JetLinksProtocolSupportProvider.class.getClassLoader()); JetLinksProtocolSupportProvider.class.getClassLoader());
support.addAuthenticator(DefaultTransport.MQTT, new JetLinksAuthenticator()); support.addAuthenticator(DefaultTransport.MQTT, new JetLinksAuthenticator());
support.addAuthenticator(DefaultTransport.MQTT_TLS, new JetLinksAuthenticator());
support.setMetadataCodec(new JetLinksDeviceMetadataCodec()); support.setMetadataCodec(new JetLinksDeviceMetadataCodec());
support.addConfigMetadata(DefaultTransport.MQTT, mqttConfig); support.addConfigMetadata(DefaultTransport.MQTT, mqttConfig);
support.addConfigMetadata(DefaultTransport.MQTT_TLS, mqttConfig);
support.addConfigMetadata(DefaultTransport.CoAP, coapConfig); support.addConfigMetadata(DefaultTransport.CoAP, coapConfig);
support.addConfigMetadata(DefaultTransport.CoAP_DTLS, coapDTLSConfig);
support.addMessageCodecSupport(new JetLinksMqttDeviceMessageCodec(DefaultTransport.MQTT)); support.addMessageCodecSupport(new JetLinksMqttDeviceMessageCodec(DefaultTransport.MQTT));
support.addMessageCodecSupport(new JetLinksMqttDeviceMessageCodec(DefaultTransport.MQTT_TLS)); support.addMessageCodecSupport(new JetLinksMqttDeviceMessageCodec(DefaultTransport.MQTT_TLS));

10
src/main/java/org/jetlinks/protocol/official/TopicMessageCodec.java
View File

@ -262,9 +262,15 @@ public enum TopicMessageCodec {
//断开连接回复 //断开连接回复
disconnectReply("/*/disconnect/reply", DisconnectDeviceMessageReply.class), 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), log("/*/log", DeviceLogMessage.class),
//状态检查 //状态检查