[inlong] branch master updated: [INLONG-5433][DataProxy] Select the corresponding configuration parameters according to the type of MQ (#5445)

[gosonzhang]

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

gosonzhang 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 508bb758a [INLONG-5433][DataProxy] Select the corresponding 
configuration parameters according to the type of MQ (#5445)
508bb758a is described below

commit 508bb758a1fc089759a1175786beb9f172cd627c
Author: Goson Zhang <4675...@qq.com>
AuthorDate: Wed Aug 10 19:23:21 2022 +0800

    [INLONG-5433][DataProxy] Select the corresponding configuration parameters 
according to the type of MQ (#5445)
---
 .../org/apache/inlong/common/pojo/dataproxy/MQClusterInfo.java   | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git 
a/inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/MQClusterInfo.java
 
b/inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/MQClusterInfo.java
index 7b7dd3179..96cf7fa37 100644
--- 
a/inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/MQClusterInfo.java
+++ 
b/inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/MQClusterInfo.java
@@ -27,6 +27,7 @@ public class MQClusterInfo {
 
     private String url;
     private String token;
+    private String mqType;
     private Map<String, String> params = new HashMap<>();
 
     public String getUrl() {
@@ -45,6 +46,14 @@ public class MQClusterInfo {
         this.token = token;
     }
 
+    public String getMqType() {
+        return mqType;
+    }
+
+    public void setMqType(String mqType) {
+        this.mqType = mqType;
+    }
+
     public Map<String, String> getParams() {
         return params;
     }