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

增加 connected disconnect

This commit is contained in:
zhou-hao 2020-08-17 18:22:27 +08:00
parent 83bbfdb4dd
commit bbf512f4b6
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/org/jetlinks/protocol/official/JetlinksTopicMessageCodec.java
View File

@ -179,14 +179,13 @@ class JetlinksTopicMessageCodec {
message = object.toJavaObject(ReportFirmwareMessage.class); message = object.toJavaObject(ReportFirmwareMessage.class);
} else if (result.isUpgradeFirmwareProgress()) { } else if (result.isUpgradeFirmwareProgress()) {
message = object.toJavaObject(UpgradeFirmwareProgressMessage.class); message = object.toJavaObject(UpgradeFirmwareProgressMessage.class);
}else if (topic.endsWith("connected")) {
message = object.toJavaObject(DeviceOnlineMessage.class);
} else if (topic.endsWith("disconnect")) {
message = object.toJavaObject(DeviceOfflineMessage.class);
} }
if (result.isChild()) { if (result.isChild()) {
if (topic.endsWith("connected")) {
message = object.toJavaObject(DeviceOnlineMessage.class);
} else if (topic.endsWith("disconnect")) {
message = object.toJavaObject(DeviceOfflineMessage.class);
}
if (message == null) { if (message == null) {
throw new UnsupportedOperationException("unsupported topic:" + topic); throw new UnsupportedOperationException("unsupported topic:" + topic);
} }