This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 6c51863fb3 [INLONG-8716][TubeMQ] set error code 0 when it works (#8724)
6c51863fb3 is described below

commit 6c51863fb3806a790796c1b84ce460028d4b24ba
Author: Goson Zhang <[email protected]>
AuthorDate: Tue Aug 15 12:53:17 2023 +0800

    [INLONG-8716][TubeMQ] set error code 0 when it works (#8724)
---
 .../org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java
 
b/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java
index e732626c7f..cf4932d976 100644
--- 
a/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java
+++ 
b/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java
@@ -561,7 +561,7 @@ public class BrokerServiceServer implements 
BrokerReadService, BrokerWriteServic
                 List<Message> messageList = 
DataConverterUtil.convertMessage(topicName, tmpMsgList);
                 int i = 0;
                 int startPos = Math.max(messageList.size() - msgCount, 0);
-                
sb.append("{\"result\":true,\"errCode\":200,\"errMsg\":\"Success!\",\"dataSet\":[");
+                
sb.append("{\"result\":true,\"errCode\":0,\"errMsg\":\"Success!\",\"dataSet\":[");
                 for (; startPos < messageList.size(); startPos++) {
                     if (i > 0) {
                         sb.append(",");

Reply via email to