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/CanalListenerAnnotationBeanPostProcessor.java | 5 +++--
1 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerAnnotationBeanPostProcessor.java b/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerAnnotationBeanPostProcessor.java
index 617c73e..02d401e 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerAnnotationBeanPostProcessor.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerAnnotationBeanPostProcessor.java
@@ -23,7 +23,6 @@
/**
* @author wuqiong 2022/4/11
- * @description
*/
public class CanalListenerAnnotationBeanPostProcessor implements
BeanPostProcessor, SmartInitializingSingleton, BeanFactoryPostProcessor {
@@ -39,15 +38,17 @@
public Object postProcessAfterInitialization(final Object bean, final String beanName) throws BeansException {
if (notAnnotatedClasses.contains(bean.getClass())) return bean;
Class<?> targetClass = AopUtils.getTargetClass(bean);
+ // 鍙壂鎻忕被鐨勬柟娉曪紝鐩墠 CanalListener 鍙敮鎸佸湪鏂规硶涓�
Map<Method, CanalListener> annotatedMethods = MethodIntrospector.selectMethods(targetClass,
(MethodIntrospector.MetadataLookup<CanalListener>) method -> findListenerAnnotations(method));
if (annotatedMethods.isEmpty()) {
this.notAnnotatedClasses.add(bean.getClass());
} else {
+ // 鍏堝姞鍏ュ埌寰呮敞鍐岄噷闈�
annotatedMethods.entrySet().stream()
.filter(e -> e != null)
.forEach(ele -> registrars.add(new CanalListenerEndpointRegistrar(bean, ele)));
- logger.info("Registered @CanalListener methods processed on bean:{} , Methods :{} ", bean.getClass().getName(),
+ logger.info("Registered @CanalListener methods processed on bean:{} , Methods :{} ", beanName,
annotatedMethods.keySet().stream().map(e -> e.getName()).collect(Collectors.toSet()));
}
return bean;
--
Gitblit v1.8.0