You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2022/08/10 11:23:25 UTC
[inlong] branch master updated: [INLONG-5433][DataProxy] Select the corresponding configuration parameters according to the type of MQ (#5445)
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 <46...@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;
}