From a8c9fe681f01793c4eadb8ed779b1b092fbd7d79 Mon Sep 17 00:00:00 2001
From: qqeasonchen <qqeasonchen@gmail.com>
Date: Sat, 12 Oct 2019 17:30:15 +0800
Subject: [PATCH] add err code when create reply message exception

---
 .../org/apache/rocketmq/client/common/ClientErrorCode.java   | 1 +
 .../java/org/apache/rocketmq/client/utils/MessageUtil.java   | 5 +++--
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/client/src/main/java/org/apache/rocketmq/client/common/ClientErrorCode.java b/client/src/main/java/org/apache/rocketmq/client/common/ClientErrorCode.java
index 633670ae..bc03b14d 100644
--- a/client/src/main/java/org/apache/rocketmq/client/common/ClientErrorCode.java
+++ b/client/src/main/java/org/apache/rocketmq/client/common/ClientErrorCode.java
@@ -24,4 +24,5 @@ public class ClientErrorCode {
     public static final int NO_NAME_SERVER_EXCEPTION = 10004;
     public static final int NOT_FOUND_TOPIC_EXCEPTION = 10005;
     public static final int REQUEST_TIMEOUT_EXCEPTION = 10006;
+    public static final int CREATE_REPLY_MESSAGE_EXCEPTION = 10007;
 }
\ No newline at end of file
diff --git a/client/src/main/java/org/apache/rocketmq/client/utils/MessageUtil.java b/client/src/main/java/org/apache/rocketmq/client/utils/MessageUtil.java
index 1e975a9a..6db470fd 100644
--- a/client/src/main/java/org/apache/rocketmq/client/utils/MessageUtil.java
+++ b/client/src/main/java/org/apache/rocketmq/client/utils/MessageUtil.java
@@ -17,6 +17,7 @@
 
 package org.apache.rocketmq.client.utils;
 
+import org.apache.rocketmq.client.common.ClientErrorCode;
 import org.apache.rocketmq.client.exception.MQClientException;
 import org.apache.rocketmq.common.MixAll;
 import org.apache.rocketmq.common.message.Message;
@@ -42,9 +43,9 @@ public class MessageUtil {
 
                 return replyMessage;
             } else {
-                throw new MQClientException(-1, "create reply message fail, requestMessage error, property[" + MessageConst.PROPERTY_CLUSTER + "] is null.");
+                throw new MQClientException(ClientErrorCode.CREATE_REPLY_MESSAGE_EXCEPTION, "create reply message fail, requestMessage error, property[" + MessageConst.PROPERTY_CLUSTER + "] is null.");
             }
         }
-        throw new MQClientException(-1, "create reply message fail, requestMessage cannot be null.");
+        throw new MQClientException(ClientErrorCode.CREATE_REPLY_MESSAGE_EXCEPTION, "create reply message fail, requestMessage cannot be null.");
     }
 }
-- 
GitLab