From 0b055a3f554da3a934e79e88c4781705cbab5a21 Mon Sep 17 00:00:00 2001
From: renxue <auster_i@163.com>
Date: 星期一, 24 十月 2022 11:40:26 +0800
Subject: [PATCH] 修改包下的类名
---
src/main/java/com/hz/canal/starter/configuration/CanalListenerAnnotationBeanPostProcessor.java | 176 +++++++++++++++++++++++++++++-----------------------------
1 files changed, 88 insertions(+), 88 deletions(-)
diff --git a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerAnnotationBeanPostProcessor.java b/src/main/java/com/hz/canal/starter/configuration/CanalListenerAnnotationBeanPostProcessor.java
similarity index 95%
rename from src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerAnnotationBeanPostProcessor.java
rename to src/main/java/com/hz/canal/starter/configuration/CanalListenerAnnotationBeanPostProcessor.java
index 64915e4..3d07141 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerAnnotationBeanPostProcessor.java
+++ b/src/main/java/com/hz/canal/starter/configuration/CanalListenerAnnotationBeanPostProcessor.java
@@ -1,88 +1,88 @@
-package com.duxinglangzi.canal.starter.configuration;
-
-
-import com.duxinglangzi.canal.starter.annotation.CanalListener;
-import com.duxinglangzi.canal.starter.factory.TransponderContainerFactory;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.aop.support.AopUtils;
-import org.springframework.beans.BeansException;
-import org.springframework.beans.factory.SmartInitializingSingleton;
-import org.springframework.beans.factory.config.BeanFactoryPostProcessor;
-import org.springframework.beans.factory.config.BeanPostProcessor;
-import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
-import org.springframework.context.ApplicationContext;
-import org.springframework.context.ApplicationContextAware;
-import org.springframework.core.MethodIntrospector;
-import org.springframework.core.annotation.AnnotatedElementUtils;
-
-import java.lang.reflect.Method;
-import java.util.Collections;
-import java.util.Map;
-import java.util.Set;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.stream.Collectors;
-
-/**
- * @author wuqiong 2022/4/11
- */
-public class CanalListenerAnnotationBeanPostProcessor implements
- BeanPostProcessor, SmartInitializingSingleton, BeanFactoryPostProcessor, ApplicationContextAware {
-
- private static final Logger logger = LoggerFactory.getLogger(CanalListenerAnnotationBeanPostProcessor.class);
-
- private final Set<Class<?>> notAnnotatedClasses = Collections.newSetFromMap(new ConcurrentHashMap<>(256));
- private Set<CanalListenerEndpointRegistrar> registrars = Collections.newSetFromMap(new ConcurrentHashMap<>());
- private ConfigurableListableBeanFactory configurableListableBeanFactory;
- private CanalAutoConfigurationProperties canalAutoConfigurationProperties;
- private ApplicationContext applicationContext;
-
- @Override
- 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(createRegistrar(bean, ele)));
- logger.info("Registered @CanalListener methods processed on bean:{} , Methods :{} ", beanName,
- annotatedMethods.keySet().stream().map(e -> e.getName()).collect(Collectors.toSet()));
- }
- return bean;
- }
-
-
- private CanalListener findListenerAnnotations(Method method) {
- return AnnotatedElementUtils.findMergedAnnotation(method, CanalListener.class);
- }
-
-
- @Override
- public void afterSingletonsInstantiated() {
- canalAutoConfigurationProperties = configurableListableBeanFactory.getBean(CanalAutoConfigurationProperties.class);
- TransponderContainerFactory.registerListenerContainer(configurableListableBeanFactory, canalAutoConfigurationProperties, registrars);
- }
-
- @Override
- public void postProcessBeanFactory(ConfigurableListableBeanFactory configurableListableBeanFactory) throws BeansException {
- this.configurableListableBeanFactory = configurableListableBeanFactory;
- }
-
- @Override
- public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
- this.applicationContext = applicationContext;
- }
-
- private CanalListenerEndpointRegistrar createRegistrar(Object bean, Map.Entry<Method, CanalListener> entry) {
- return new CanalListenerEndpointRegistrar(bean, entry.getKey(),
- applicationContext.getEnvironment().resolvePlaceholders(entry.getValue().destination()),
- applicationContext.getEnvironment().resolvePlaceholders(entry.getValue().database()),
- entry.getValue().table(), entry.getValue().eventType());
- }
-}
+package com.hz.canal.starter.configuration;
+
+
+import com.hz.canal.starter.annotation.CanalListener;
+import com.hz.canal.starter.factory.TransponderContainerFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.aop.support.AopUtils;
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.SmartInitializingSingleton;
+import org.springframework.beans.factory.config.BeanFactoryPostProcessor;
+import org.springframework.beans.factory.config.BeanPostProcessor;
+import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.core.MethodIntrospector;
+import org.springframework.core.annotation.AnnotatedElementUtils;
+
+import java.lang.reflect.Method;
+import java.util.Collections;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.stream.Collectors;
+
+/**
+ * @author wuqiong 2022/4/11
+ */
+public class CanalListenerAnnotationBeanPostProcessor implements
+ BeanPostProcessor, SmartInitializingSingleton, BeanFactoryPostProcessor, ApplicationContextAware {
+
+ private static final Logger logger = LoggerFactory.getLogger(CanalListenerAnnotationBeanPostProcessor.class);
+
+ private final Set<Class<?>> notAnnotatedClasses = Collections.newSetFromMap(new ConcurrentHashMap<>(256));
+ private Set<CanalListenerEndpointRegistrar> registrars = Collections.newSetFromMap(new ConcurrentHashMap<>());
+ private ConfigurableListableBeanFactory configurableListableBeanFactory;
+ private CanalAutoConfigurationProperties canalAutoConfigurationProperties;
+ private ApplicationContext applicationContext;
+
+ @Override
+ 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(createRegistrar(bean, ele)));
+ logger.info("Registered @CanalListener methods processed on bean:{} , Methods :{} ", beanName,
+ annotatedMethods.keySet().stream().map(e -> e.getName()).collect(Collectors.toSet()));
+ }
+ return bean;
+ }
+
+
+ private CanalListener findListenerAnnotations(Method method) {
+ return AnnotatedElementUtils.findMergedAnnotation(method, CanalListener.class);
+ }
+
+
+ @Override
+ public void afterSingletonsInstantiated() {
+ canalAutoConfigurationProperties = configurableListableBeanFactory.getBean(CanalAutoConfigurationProperties.class);
+ TransponderContainerFactory.registerListenerContainer(configurableListableBeanFactory, canalAutoConfigurationProperties, registrars);
+ }
+
+ @Override
+ public void postProcessBeanFactory(ConfigurableListableBeanFactory configurableListableBeanFactory) throws BeansException {
+ this.configurableListableBeanFactory = configurableListableBeanFactory;
+ }
+
+ @Override
+ public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+ this.applicationContext = applicationContext;
+ }
+
+ private CanalListenerEndpointRegistrar createRegistrar(Object bean, Map.Entry<Method, CanalListener> entry) {
+ return new CanalListenerEndpointRegistrar(bean, entry.getKey(),
+ applicationContext.getEnvironment().resolvePlaceholders(entry.getValue().destination()),
+ applicationContext.getEnvironment().resolvePlaceholders(entry.getValue().database()),
+ entry.getValue().table(), entry.getValue().eventType());
+ }
+}
--
Gitblit v1.8.0