[incubator-inlong] branch master updated: fix requestId is not set in response message (#2208)

[dockerzhang]

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/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 8b485e0  fix requestId is not set in response message (#2208)
8b485e0 is described below

commit 8b485e09acf8850b766574730388565657228e23
Author: baomingyu <baomingy...@163.com>
AuthorDate: Thu Jan 20 12:02:30 2022 +0800

    fix requestId is not set in response message (#2208)
---
 .../java/org/apache/inlong/audit/source/ServerMessageHandler.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/inlong-audit/audit-source/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
 
b/inlong-audit/audit-source/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
index 77e3d9a..c0d3723 100644
--- 
a/inlong-audit/audit-source/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
+++ 
b/inlong-audit/audit-source/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
@@ -179,14 +179,16 @@ public class ServerMessageHandler extends 
SimpleChannelHandler {
                     }
                 }
                 if (errorMsgBody != 0) {
-                    reply = AuditReply.newBuilder().setMessage("Error writing 
to controller,data "
+                    reply = 
AuditReply.newBuilder().setRequestId(auditRequest.getRequestId())
+                            .setMessage("Error writing to controller,data "
                             + "will discard. error body num = "
                             + 
errorMsgBody).setRspCode(RSP_CODE.FAILED).build();
                 }
             }
         }
         if (reply == null) {
-            reply = 
AuditReply.newBuilder().setRspCode(RSP_CODE.SUCCESS).build();
+            reply = 
AuditReply.newBuilder().setRequestId(auditRequest.getRequestId())
+                    .setRspCode(RSP_CODE.SUCCESS).build();
         }
         return reply;
     }