From 7cf9781edf66c75570af378a96b4011ff63ada92 Mon Sep 17 00:00:00 2001
From: duxinglangzi <871364441@qq.com>
Date: 星期一, 16 五月 2022 13:07:01 +0800
Subject: [PATCH] 格式化
---
src/main/java/com/duxinglangzi/canal/starter/configuration/CanalAutoConfigurationProperties.java | 8 ++++----
src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java | 3 ++-
src/main/java/com/duxinglangzi/canal/starter/factory/TransponderContainerFactory.java | 1 +
src/main/java/com/duxinglangzi/canal/starter/container/AbstractCanalTransponderContainer.java | 5 ++++-
src/main/java/com/duxinglangzi/canal/starter/configuration/CanalConfigurationSelector.java | 1 +
src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerEndpointRegistrar.java | 3 +++
src/main/java/com/duxinglangzi/canal/starter/configuration/CanalBootstrapConfiguration.java | 1 +
src/main/java/com/duxinglangzi/canal/starter/factory/CanalConnectorFactory.java | 1 +
src/main/java/com/duxinglangzi/canal/starter/listener/ApplicationReadyListener.java | 2 +-
9 files changed, 18 insertions(+), 7 deletions(-)
diff --git a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalAutoConfigurationProperties.java b/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalAutoConfigurationProperties.java
index 430dd22..4e1266d 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalAutoConfigurationProperties.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalAutoConfigurationProperties.java
@@ -9,6 +9,7 @@
/**
* Canal杩炴帴鐨勯厤缃被
+ *
* @author wuqiong 2022/4/11
*/
@Order(Ordered.HIGHEST_PRECEDENCE)
@@ -60,20 +61,19 @@
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 = ".*\\..*";
diff --git a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalBootstrapConfiguration.java b/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalBootstrapConfiguration.java
index f6f4bbb..4ec1a93 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalBootstrapConfiguration.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalBootstrapConfiguration.java
@@ -15,6 +15,7 @@
/**
* 娉ㄥ唽 CanalListenerAnnotationBeanPostProcessor 鍒皊pring bean 瀹瑰櫒鍐�
+ *
* @param importingClassMetadata
* @param registry
* @return void
diff --git a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalConfigurationSelector.java b/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalConfigurationSelector.java
index a6adcd1..0c9da65 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalConfigurationSelector.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalConfigurationSelector.java
@@ -10,6 +10,7 @@
/**
* 鎵弿鍣� 瀵煎叆鎸囧畾绫伙紝 杩欓噷瀵煎叆 CanalBootstrapConfiguration.class
+ *
* @param importingClassMetadata
* @return java.lang.String[]
* @author wuqiong 2022-04-23 20:20
diff --git a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerEndpointRegistrar.java b/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerEndpointRegistrar.java
index e1a4d8a..aa2cc0b 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerEndpointRegistrar.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerEndpointRegistrar.java
@@ -15,6 +15,7 @@
/**
* 鐧昏鍛�
+ *
* @author wuqiong 2022/4/11
*/
public class CanalListenerEndpointRegistrar {
@@ -26,6 +27,7 @@
* 1銆佺洰鍓嶅疄鐜扮殑 DML 瑙ｆ瀽鍣ㄤ粎鏀寔涓や釜鍙傛暟 <p>
* 2銆佷笖椤哄簭蹇呴』涓�: CanalEntry.EventType 銆� CanalEntry.RowData <p>
* 3銆佸鏋淐analListener 鎸囧畾鐨� destination 涓嶅湪閰嶇疆鏂囦欢鍐咃紝鍒欑洿鎺ユ姏閿� <p>
+ *
* @param sets
* @return void
* @author wuqiong 2022-04-23 20:27
@@ -55,6 +57,7 @@
/**
* 杩囨护鍙傛暟
+ *
* @param database
* @param tableName
* @param eventType
diff --git a/src/main/java/com/duxinglangzi/canal/starter/container/AbstractCanalTransponderContainer.java b/src/main/java/com/duxinglangzi/canal/starter/container/AbstractCanalTransponderContainer.java
index 2ded94c..9cfe177 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/container/AbstractCanalTransponderContainer.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/container/AbstractCanalTransponderContainer.java
@@ -10,6 +10,7 @@
/**
* 鎶借薄鐨刢anal transponder ,瀹炵幇SmartLifecycle鎺ュ彛,澹版槑鍛ㄦ湡鐢眘pring杩涜绠＄悊
+ *
* @author wuqiong 2022/4/11
*/
public abstract class AbstractCanalTransponderContainer implements SmartLifecycle {
@@ -21,7 +22,9 @@
CanalEntry.EntryType.HEARTBEAT);
protected abstract void doStart();
+
protected abstract void initConnect();
+
protected abstract void disconnect();
@@ -55,7 +58,7 @@
return isRunning;
}
- protected void setRunning(boolean bool){
+ protected void setRunning(boolean bool) {
isRunning = bool;
}
diff --git a/src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java b/src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java
index 295ece6..4214713 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java
@@ -13,6 +13,7 @@
/**
* DML 鏁版嵁鎷夊彇銆佽В鏋�
+ *
* @author wuqiong 2022/4/11
*/
public class DmlMessageTransponderContainer extends AbstractCanalTransponderContainer {
@@ -40,7 +41,7 @@
}
- public void disconnect(){
+ public void disconnect() {
// 鍏抽棴杩炴帴
connector.disconnect();
}
diff --git a/src/main/java/com/duxinglangzi/canal/starter/factory/CanalConnectorFactory.java b/src/main/java/com/duxinglangzi/canal/starter/factory/CanalConnectorFactory.java
index d1ed7cd..0ce17db 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/factory/CanalConnectorFactory.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/factory/CanalConnectorFactory.java
@@ -17,6 +17,7 @@
/**
* 鍒涘缓 CanalConnector
+ *
* @param destination
* @param endpointInstance
* @return CanalConnector
diff --git a/src/main/java/com/duxinglangzi/canal/starter/factory/TransponderContainerFactory.java b/src/main/java/com/duxinglangzi/canal/starter/factory/TransponderContainerFactory.java
index e050ab2..bc051cd 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/factory/TransponderContainerFactory.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/factory/TransponderContainerFactory.java
@@ -22,6 +22,7 @@
/**
* 灏嗘墍鏈夊緟娉ㄥ唽鐨勭鐐癸紝娉ㄥ唽鍒皊pring涓�
+ *
* @param beanFactory
* @param canalConfig
* @param registrars
diff --git a/src/main/java/com/duxinglangzi/canal/starter/listener/ApplicationReadyListener.java b/src/main/java/com/duxinglangzi/canal/starter/listener/ApplicationReadyListener.java
index b6d7498..161742f 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/listener/ApplicationReadyListener.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/listener/ApplicationReadyListener.java
@@ -8,7 +8,7 @@
/**
* @author wuqiong 2022/4/16
*/
-public class ApplicationReadyListener implements ApplicationListener<ApplicationReadyEvent>{
+public class ApplicationReadyListener implements ApplicationListener<ApplicationReadyEvent> {
public static final AtomicBoolean START_LISTENER_CONTAINER = new AtomicBoolean(false);
--
Gitblit v1.8.0