From 0b055a3f554da3a934e79e88c4781705cbab5a21 Mon Sep 17 00:00:00 2001
From: renxue <auster_i@163.com>
Date: 星期一, 24 十月 2022 11:40:26 +0800
Subject: [PATCH] 修改包下的类名
---
src/main/java/com/hz/canal/starter/configuration/CanalAutoConfigurationProperties.java | 354 +++++++++++++++++++++++++++++-----------------------------
1 files changed, 177 insertions(+), 177 deletions(-)
diff --git a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalAutoConfigurationProperties.java b/src/main/java/com/hz/canal/starter/configuration/CanalAutoConfigurationProperties.java
similarity index 98%
rename from src/main/java/com/duxinglangzi/canal/starter/configuration/CanalAutoConfigurationProperties.java
rename to src/main/java/com/hz/canal/starter/configuration/CanalAutoConfigurationProperties.java
index 4e1266d..8dea5bc 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalAutoConfigurationProperties.java
+++ b/src/main/java/com/hz/canal/starter/configuration/CanalAutoConfigurationProperties.java
@@ -1,177 +1,177 @@
-package com.duxinglangzi.canal.starter.configuration;
-
-import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.springframework.core.Ordered;
-import org.springframework.core.annotation.Order;
-
-import java.util.LinkedHashMap;
-import java.util.Map;
-
-/**
- * Canal杩炴帴鐨勯厤缃被
- *
- * @author wuqiong 2022/4/11
- */
-@Order(Ordered.HIGHEST_PRECEDENCE)
-@ConfigurationProperties(prefix = "spring.canal")
-public class CanalAutoConfigurationProperties {
-
- private Map<String, EndpointInstance> instances = new LinkedHashMap<>();
-
- public static class EndpointInstance {
-
- /**
- * 鏄惁寮�鍚� cluster
- */
- private boolean clusterEnabled;
-
- /**
- * zookeeper 鍦板潃, 渚�: 192.168.0.1:2181,192.168.0.2:2181,192.168.0.3:2181
- */
- private String zookeeperAddress;
-
- /**
- * 榛樿 127.0.0.1
- */
- private String host = "127.0.0.1";
-
- /**
- * 绔彛 , 榛樿: 11111
- */
- private int port = 11111;
-
- /**
- * 鐢ㄦ埛鍚�
- */
- private String userName = "";
-
- /**
- * 瀵嗙爜
- */
- private String password = "";
-
- /**
- * 姣忔鑾峰彇鏁版嵁鏉℃暟 , 榛樿: 200
- */
- private int batchSize = 200;
-
- /**
- * 鍙戠敓閿欒鏃堕噸璇曟鏁� , 榛樿: 5
- */
- private int retryCount = 5;
-
- /**
- * mysql 鏁版嵁瑙ｆ瀽鍏虫敞鐨勮〃锛孭erl姝ｅ垯琛ㄨ揪寮�.
- * <p>
- * <p>
- * 澶氫釜姝ｅ垯涔嬮棿浠ラ�楀彿(,)鍒嗛殧锛岃浆涔夌闇�瑕佸弻鏂滄潬(\\)
- * <p>
- * <p>
- * 甯歌渚嬪瓙锛� <p>
- * 1. 鎵�鏈夊簱琛細.* or .*\\..* <p>
- * 2. canal_db 涓嬫墍鏈夎〃锛� canal_db\\..* <p>
- * 3. canal_db 涓嬬殑浠anal鎵撳ご鐨勮〃锛� canal_db\\.canal.* <p>
- * 4. canal_db 涓嬬殑涓�寮犺〃锛� canal_db\\.test1 <p>
- * 5. 澶氫釜瑙勫垯缁勫悎浣跨敤锛歝anal_db\\..*,mysql_db.test1,mysql.test2 (閫楀彿鍒嗛殧) <p>
- * <p>
- * 榛樿: 鍏ㄥ簱鍏ㄨ〃(.*\\..*)
- */
- private String subscribe = ".*\\..*";
-
- /**
- * 鏈媺鍙栧埌娑堟伅鎯呭喌涓�,鑾峰彇娑堟伅鐨勬椂闂撮棿闅旀绉掑�� , 榛樿: 1000
- */
- private long acquireInterval = 1000;
-
- public EndpointInstance() {
- }
-
- public boolean isClusterEnabled() {
- return clusterEnabled;
- }
-
- public void setClusterEnabled(boolean clusterEnabled) {
- this.clusterEnabled = clusterEnabled;
- }
-
- public String getZookeeperAddress() {
- return zookeeperAddress;
- }
-
- public void setZookeeperAddress(String zookeeperAddress) {
- this.zookeeperAddress = zookeeperAddress;
- }
-
- public String getHost() {
- return host;
- }
-
- public void setHost(String host) {
- this.host = host;
- }
-
- public int getPort() {
- return port;
- }
-
- public void setPort(int port) {
- this.port = port;
- }
-
- public String getUserName() {
- return userName;
- }
-
- public void setUserName(String userName) {
- this.userName = userName;
- }
-
- public String getPassword() {
- return password;
- }
-
- public void setPassword(String password) {
- this.password = password;
- }
-
- public int getBatchSize() {
- return batchSize;
- }
-
- public void setBatchSize(int batchSize) {
- this.batchSize = batchSize;
- }
-
- public int getRetryCount() {
- return retryCount;
- }
-
- public void setRetryCount(int retryCount) {
- this.retryCount = retryCount;
- }
-
- public long getAcquireInterval() {
- return acquireInterval;
- }
-
- public void setAcquireInterval(long acquireInterval) {
- this.acquireInterval = acquireInterval;
- }
-
- public String getSubscribe() {
- return subscribe;
- }
-
- public void setSubscribe(String subscribe) {
- this.subscribe = subscribe;
- }
- }
-
- public Map<String, EndpointInstance> getInstances() {
- return instances;
- }
-
- public void setInstances(Map<String, EndpointInstance> instances) {
- this.instances = instances;
- }
-}
+package com.hz.canal.starter.configuration;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.core.Ordered;
+import org.springframework.core.annotation.Order;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+/**
+ * Canal杩炴帴鐨勯厤缃被
+ *
+ * @author wuqiong 2022/4/11
+ */
+@Order(Ordered.HIGHEST_PRECEDENCE)
+@ConfigurationProperties(prefix = "spring.canal")
+public class CanalAutoConfigurationProperties {
+
+ private Map<String, EndpointInstance> instances = new LinkedHashMap<>();
+
+ public static class EndpointInstance {
+
+ /**
+ * 鏄惁寮�鍚� cluster
+ */
+ private boolean clusterEnabled;
+
+ /**
+ * zookeeper 鍦板潃, 渚�: 192.168.0.1:2181,192.168.0.2:2181,192.168.0.3:2181
+ */
+ private String zookeeperAddress;
+
+ /**
+ * 榛樿 127.0.0.1
+ */
+ private String host = "127.0.0.1";
+
+ /**
+ * 绔彛 , 榛樿: 11111
+ */
+ private int port = 11111;
+
+ /**
+ * 鐢ㄦ埛鍚�
+ */
+ private String userName = "";
+
+ /**
+ * 瀵嗙爜
+ */
+ private String password = "";
+
+ /**
+ * 姣忔鑾峰彇鏁版嵁鏉℃暟 , 榛樿: 200
+ */
+ private int batchSize = 200;
+
+ /**
+ * 鍙戠敓閿欒鏃堕噸璇曟鏁� , 榛樿: 5
+ */
+ private int retryCount = 5;
+
+ /**
+ * mysql 鏁版嵁瑙ｆ瀽鍏虫敞鐨勮〃锛孭erl姝ｅ垯琛ㄨ揪寮�.
+ * <p>
+ * <p>
+ * 澶氫釜姝ｅ垯涔嬮棿浠ラ�楀彿(,)鍒嗛殧锛岃浆涔夌闇�瑕佸弻鏂滄潬(\\)
+ * <p>
+ * <p>
+ * 甯歌渚嬪瓙锛� <p>
+ * 1. 鎵�鏈夊簱琛細.* or .*\\..* <p>
+ * 2. canal_db 涓嬫墍鏈夎〃锛� canal_db\\..* <p>
+ * 3. canal_db 涓嬬殑浠anal鎵撳ご鐨勮〃锛� canal_db\\.canal.* <p>
+ * 4. canal_db 涓嬬殑涓�寮犺〃锛� canal_db\\.test1 <p>
+ * 5. 澶氫釜瑙勫垯缁勫悎浣跨敤锛歝anal_db\\..*,mysql_db.test1,mysql.test2 (閫楀彿鍒嗛殧) <p>
+ * <p>
+ * 榛樿: 鍏ㄥ簱鍏ㄨ〃(.*\\..*)
+ */
+ private String subscribe = ".*\\..*";
+
+ /**
+ * 鏈媺鍙栧埌娑堟伅鎯呭喌涓�,鑾峰彇娑堟伅鐨勬椂闂撮棿闅旀绉掑�� , 榛樿: 1000
+ */
+ private long acquireInterval = 1000;
+
+ public EndpointInstance() {
+ }
+
+ public boolean isClusterEnabled() {
+ return clusterEnabled;
+ }
+
+ public void setClusterEnabled(boolean clusterEnabled) {
+ this.clusterEnabled = clusterEnabled;
+ }
+
+ public String getZookeeperAddress() {
+ return zookeeperAddress;
+ }
+
+ public void setZookeeperAddress(String zookeeperAddress) {
+ this.zookeeperAddress = zookeeperAddress;
+ }
+
+ public String getHost() {
+ return host;
+ }
+
+ public void setHost(String host) {
+ this.host = host;
+ }
+
+ public int getPort() {
+ return port;
+ }
+
+ public void setPort(int port) {
+ this.port = port;
+ }
+
+ public String getUserName() {
+ return userName;
+ }
+
+ public void setUserName(String userName) {
+ this.userName = userName;
+ }
+
+ public String getPassword() {
+ return password;
+ }
+
+ public void setPassword(String password) {
+ this.password = password;
+ }
+
+ public int getBatchSize() {
+ return batchSize;
+ }
+
+ public void setBatchSize(int batchSize) {
+ this.batchSize = batchSize;
+ }
+
+ public int getRetryCount() {
+ return retryCount;
+ }
+
+ public void setRetryCount(int retryCount) {
+ this.retryCount = retryCount;
+ }
+
+ public long getAcquireInterval() {
+ return acquireInterval;
+ }
+
+ public void setAcquireInterval(long acquireInterval) {
+ this.acquireInterval = acquireInterval;
+ }
+
+ public String getSubscribe() {
+ return subscribe;
+ }
+
+ public void setSubscribe(String subscribe) {
+ this.subscribe = subscribe;
+ }
+ }
+
+ public Map<String, EndpointInstance> getInstances() {
+ return instances;
+ }
+
+ public void setInstances(Map<String, EndpointInstance> instances) {
+ this.instances = instances;
+ }
+}
--
Gitblit v1.8.0