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/factory/TransponderContainerFactory.java | 11 ++++++++++-
1 files changed, 10 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..bc051cd 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,15 @@
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 +39,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