From 6274208525b7e80c208f614915ef973d63834101 Mon Sep 17 00:00:00 2001
From: duxinglangzi <871364441@qq.com>
Date: 星期六, 23 四月 2022 20:52:14 +0800
Subject: [PATCH] 修改部分注释内容
---
src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerEndpointRegistrar.java | 18 +++++++++++++++++-
1 files changed, 17 insertions(+), 1 deletions(-)
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 0b19476..e1a4d8a 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerEndpointRegistrar.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerEndpointRegistrar.java
@@ -14,14 +14,22 @@
import java.util.stream.Collectors;
/**
+ * 鐧昏鍛�
* @author wuqiong 2022/4/11
- * @description
*/
public class CanalListenerEndpointRegistrar {
private Object bean;
private Map.Entry<Method, CanalListener> listenerEntry;
+ /**
+ * 1銆佺洰鍓嶅疄鐜扮殑 DML 瑙ｆ瀽鍣ㄤ粎鏀寔涓や釜鍙傛暟 <p>
+ * 2銆佷笖椤哄簭蹇呴』涓�: CanalEntry.EventType 銆� CanalEntry.RowData <p>
+ * 3銆佸鏋淐analListener 鎸囧畾鐨� destination 涓嶅湪閰嶇疆鏂囦欢鍐咃紝鍒欑洿鎺ユ姏閿� <p>
+ * @param sets
+ * @return void
+ * @author wuqiong 2022-04-23 20:27
+ */
public void checkParameter(Set<String> sets) {
List<Class<?>> classes = parameterTypes();
if (classes.size() > 2
@@ -45,6 +53,14 @@
return getListenerEntry().getValue().destination().equals(destination);
}
+ /**
+ * 杩囨护鍙傛暟
+ * @param database
+ * @param tableName
+ * @param eventType
+ * @return java.util.function.Predicate
+ * @author wuqiong 2022-04-23 20:47
+ */
public static Predicate<CanalListenerEndpointRegistrar> filterArgs(
String database, String tableName, CanalEntry.EventType eventType) {
Predicate<CanalListenerEndpointRegistrar> databases = e -> StringUtils.isBlank(e.getListenerEntry().getValue().database())
--
Gitblit v1.8.0