From 89fd9bf38ceea9c49a24ccbd361eb51215702686 Mon Sep 17 00:00:00 2001
From: zhou-hao <admin@hsweb.me>
Date: Wed, 20 Oct 2021 09:18:16 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=9C=AA=E5=9B=9E=E5=A4=8D?=
 =?UTF-8?q?=E5=AD=90=E8=AE=BE=E5=A4=87=E6=8C=87=E4=BB=A4=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../community/device/message/DeviceMessageConnector.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/message/DeviceMessageConnector.java b/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/message/DeviceMessageConnector.java
index 9d9ffc3a..3a492a6b 100644
--- a/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/message/DeviceMessageConnector.java
+++ b/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/message/DeviceMessageConnector.java
@@ -281,7 +281,11 @@ public class DeviceMessageConnector implements DecodedClientMessageHandler {
     public Mono<Boolean> handleMessage(DeviceOperator device, @Nonnull Message message) {
         Mono<Boolean> then;
         if (message instanceof ChildDeviceMessageReply) {
-            then = handleChildrenDeviceMessageReply(((ChildDeviceMessageReply) message));
+            then = this
+                .doReply(((ChildDeviceMessageReply) message))
+                .then(
+                    handleChildrenDeviceMessageReply(((ChildDeviceMessageReply) message))
+                );
         } else if (message instanceof ChildDeviceMessage) {
             then = handleChildrenDeviceMessageReply(((ChildDeviceMessage) message));
         } else if (message instanceof DeviceMessageReply) {