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 handleMessage(DeviceOperator device, @Nonnull Message message) { Mono 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) {