From 57b0cb0a7374fba500738836acfcf1d35c4b0466 Mon Sep 17 00:00:00 2001
From: zhouhao <zh.sqy@qq.com>
Date: Mon, 26 Dec 2022 14:00:10 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../jetlinks/protocol/official/tcp/TcpDeviceMessageCodec.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/main/java/org/jetlinks/protocol/official/tcp/TcpDeviceMessageCodec.java b/src/main/java/org/jetlinks/protocol/official/tcp/TcpDeviceMessageCodec.java
index 046405d..d9e4693 100644
--- 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());