优化

2022-12-26 14:00:10 +08:00 · 2022-12-26 14:00:10 +08:00 · 57b0cb0a73
parent b92c9b5564
commit 57b0cb0a73
1 changed files with 3 additions and 0 deletions
--- a/src/main/java/org/jetlinks/protocol/official/tcp/TcpDeviceMessageCodec.java
+++ b/src/main/java/org/jetlinks/protocol/official/tcp/TcpDeviceMessageCodec.java
@ -80,6 +80,9 @@ public class TcpDeviceMessageCodec implements DeviceMessageCodec {
    }

    private <T> Mono<T> ack(DeviceMessage source, AckCode code, MessageDecodeContext context) {
+        if(source==null){
+            return Mono.empty();
+        }
        AcknowledgeDeviceMessage message = new AcknowledgeDeviceMessage();
        message.addHeader(BinaryAcknowledgeDeviceMessage.codeHeader, code.name());
        message.setDeviceId(source.getDeviceId());