From d3aa68df05e86089f7525f9a4e3b341ace225e53 Mon Sep 17 00:00:00 2001 From: "heavyrain.lee" Date: Sun, 26 May 2019 23:46:42 +0800 Subject: [PATCH] fix error --- broker/src/main/java/io/moquette/persistence/RPCCenter.java | 2 +- .../src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/broker/src/main/java/io/moquette/persistence/RPCCenter.java b/broker/src/main/java/io/moquette/persistence/RPCCenter.java index 3d112767..9b98cad6 100644 --- a/broker/src/main/java/io/moquette/persistence/RPCCenter.java +++ b/broker/src/main/java/io/moquette/persistence/RPCCenter.java @@ -73,7 +73,7 @@ public class RPCCenter { info.future.cancel(true); if (info.callback != null) { info.callback.getResponseExecutor().execute(() -> { - if (errorCode == 0 || errorCode == ErrorCode.ERROR_CODE_ASYNC_HANDLER.getCode()) { + if (errorCode == 0 || errorCode == ErrorCode.ERROR_CODE_SUCCESS_GZIPED.getCode()) { info.callback.onSuccess(message); } else { info.callback.onError(ErrorCode.fromCode(errorCode)); diff --git a/broker/src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java b/broker/src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java index 2665d1b9..413fa7d3 100755 --- a/broker/src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java +++ b/broker/src/main/java/io/moquette/spi/impl/Qos1PublishHandler.java @@ -188,7 +188,7 @@ public class Qos1PublishHandler extends QosPublishHandler { e.printStackTrace(); } data = out.toByteArray(); - code = (byte)ErrorCode.ERROR_CODE_ASYNC_HANDLER.code; + code = (byte)ErrorCode.ERROR_CODE_SUCCESS_GZIPED.code; } data = AES.AESEncrypt(data, session.getSecret());