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());