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/factory/TransponderContainerFactory.java | 10 +++++++++-
1 files changed, 9 insertions(+), 1 deletions(-)
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 bec75d0..e050ab2 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/factory/TransponderContainerFactory.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/factory/TransponderContainerFactory.java
@@ -20,6 +20,14 @@
private static final String CONTAINER_ID_PREFIX = "com.duxinglangzi.canal.starter.container.MessageTransponderContainer#";
+ /**
+ * 灏嗘墍鏈夊緟娉ㄥ唽鐨勭鐐癸紝娉ㄥ唽鍒皊pring涓�
+ * @param beanFactory
+ * @param canalConfig
+ * @param registrars
+ * @return void
+ * @author wuqiong 2022-04-23 20:34
+ */
public static void registerListenerContainer(
ConfigurableListableBeanFactory beanFactory, CanalAutoConfigurationProperties canalConfig,
Set<CanalListenerEndpointRegistrar> registrars) {
@@ -30,8 +38,8 @@
if (beanFactory.containsBean(getContainerID(endpointInstance.getKey()))) continue; // 濡傛灉宸茬粡瀛樺湪鍒欎笉鍦ㄥ垱寤�
List<CanalListenerEndpointRegistrar> registrarList = new ArrayList<>();
for (CanalListenerEndpointRegistrar registrar : registrars) {
- if (!registrar.isContainDestination(endpointInstance.getKey())) continue;
registrar.checkParameter(canalConfig.getInstances().keySet());
+ if (!registrar.isContainDestination(endpointInstance.getKey())) continue;
registrarList.add(registrar);
}
if (registrarList.isEmpty()) continue;
--
Gitblit v1.8.0