修改包下的类名

renxue

2022-10-24 0b055a3f554da3a934e79e88c4781705cbab5a21

修改包下的类名

 README.md

@@ -28,11 +28,11 @@




import com.alibaba.otter.canal.protocol.CanalEntry;

import com.duxinglangzi.canal.starter.annotation.CanalInsertListener;

import com.duxinglangzi.canal.starter.annotation.CanalListener;

import com.duxinglangzi.canal.starter.annotation.CanalUpdateListener;

import com.duxinglangzi.canal.starter.annotation.EnableCanalListener;

import com.duxinglangzi.canal.starter.mode.CanalMessage;

import CanalInsertListener;

import CanalListener;

import CanalUpdateListener;

import EnableCanalListener;

import CanalMessage;

import org.springframework.stereotype.Service;



import java.util.stream.Collectors;

@@ -48,7 +48,7 @@
    /**

     * 必须在类上 使用 EnableCanalListener 注解才能开启 canal listener

     *

     * 目前 Listener 方法的参数必须为 com.duxinglangzi.canal.starter.mode.CanalMessage

     * 目前 Listener 方法的参数必须为 CanalMessage

     * 程序在启动过程中会做检查

     */




 src/main/java/com/duxinglangzi/canal/starter/annotation/EnableCanalListener.java

File was deleted

 src/main/java/com/hz/canal/starter/annotation/CanalDeleteListener.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/annotation/CanalDeleteListener.java
@@ -1,4 +1,4 @@
package com.duxinglangzi.canal.starter.annotation;

package com.hz.canal.starter.annotation;




import com.alibaba.otter.canal.protocol.CanalEntry;


 src/main/java/com/hz/canal/starter/annotation/CanalInsertListener.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/annotation/CanalInsertListener.java
@@ -1,4 +1,4 @@
package com.duxinglangzi.canal.starter.annotation;

package com.hz.canal.starter.annotation;




import com.alibaba.otter.canal.protocol.CanalEntry;


 src/main/java/com/hz/canal/starter/annotation/CanalListener.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/annotation/CanalListener.java
@@ -1,4 +1,4 @@
package com.duxinglangzi.canal.starter.annotation;

package com.hz.canal.starter.annotation;




import com.alibaba.otter.canal.protocol.CanalEntry;


 src/main/java/com/hz/canal/starter/annotation/CanalUpdateListener.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/annotation/CanalUpdateListener.java
@@ -1,4 +1,4 @@
package com.duxinglangzi.canal.starter.annotation;

package com.hz.canal.starter.annotation;




import com.alibaba.otter.canal.protocol.CanalEntry;


 src/main/java/com/hz/canal/starter/annotation/EnableCanalListener.java

New file
@@ -0,0 +1,21 @@
package com.hz.canal.starter.annotation;

import com.hz.canal.starter.configuration.CanalAutoConfigurationProperties;
import com.hz.canal.starter.configuration.CanalConfigurationSelector;
import com.hz.canal.starter.listener.ApplicationReadyListener;
import org.springframework.context.annotation.Import;

import java.lang.annotation.*;

/**
 * 开启 canal listener
 *
 * @author wuqiong 2022/8/4
 */
@Documented
@Inherited
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Import({CanalAutoConfigurationProperties.class, CanalConfigurationSelector.class, ApplicationReadyListener.class})
public @interface EnableCanalListener {
}

 src/main/java/com/hz/canal/starter/configuration/CanalAutoConfigurationProperties.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/configuration/CanalAutoConfigurationProperties.java
@@ -1,4 +1,4 @@
package com.duxinglangzi.canal.starter.configuration;

package com.hz.canal.starter.configuration;


import org.springframework.boot.context.properties.ConfigurationProperties;

import org.springframework.core.Ordered;


 src/main/java/com/hz/canal/starter/configuration/CanalBootstrapConfiguration.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/configuration/CanalBootstrapConfiguration.java
@@ -1,4 +1,4 @@
package com.duxinglangzi.canal.starter.configuration;

package com.hz.canal.starter.configuration;


import org.springframework.beans.factory.support.BeanDefinitionRegistry;

import org.springframework.beans.factory.support.RootBeanDefinition;


 src/main/java/com/hz/canal/starter/configuration/CanalConfigurationSelector.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/configuration/CanalConfigurationSelector.java
@@ -1,4 +1,4 @@
package com.duxinglangzi.canal.starter.configuration;

package com.hz.canal.starter.configuration;


import org.springframework.context.annotation.DeferredImportSelector;

import org.springframework.core.type.AnnotationMetadata;


 src/main/java/com/hz/canal/starter/configuration/CanalListenerAnnotationBeanPostProcessor.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerAnnotationBeanPostProcessor.java
@@ -1,8 +1,8 @@
package com.duxinglangzi.canal.starter.configuration;

package com.hz.canal.starter.configuration;




import com.duxinglangzi.canal.starter.annotation.CanalListener;

import com.duxinglangzi.canal.starter.factory.TransponderContainerFactory;

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;


 src/main/java/com/hz/canal/starter/configuration/CanalListenerEndpointRegistrar.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerEndpointRegistrar.java
@@ -1,8 +1,8 @@
package com.duxinglangzi.canal.starter.configuration;

package com.hz.canal.starter.configuration;


import com.alibaba.otter.canal.protocol.CanalEntry;

import com.alibaba.otter.canal.protocol.exception.CanalClientException;

import com.duxinglangzi.canal.starter.mode.CanalMessage;

import com.hz.canal.starter.mode.CanalMessage;
import org.apache.commons.lang3.StringUtils;



import java.lang.reflect.Method;


 src/main/java/com/hz/canal/starter/container/AbstractCanalTransponderContainer.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/container/AbstractCanalTransponderContainer.java
@@ -1,7 +1,7 @@
package com.duxinglangzi.canal.starter.container;

package com.hz.canal.starter.container;


import com.alibaba.otter.canal.protocol.CanalEntry;

import com.duxinglangzi.canal.starter.listener.ApplicationReadyListener;

import com.hz.canal.starter.listener.ApplicationReadyListener;
import org.springframework.context.SmartLifecycle;



import java.util.Arrays;


 src/main/java/com/hz/canal/starter/container/DmlMessageTransponderContainer.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java
@@ -1,11 +1,11 @@
package com.duxinglangzi.canal.starter.container;

package com.hz.canal.starter.container;


import com.alibaba.otter.canal.client.CanalConnector;

import com.alibaba.otter.canal.protocol.CanalEntry;

import com.alibaba.otter.canal.protocol.Message;

import com.duxinglangzi.canal.starter.configuration.CanalAutoConfigurationProperties;

import com.duxinglangzi.canal.starter.configuration.CanalListenerEndpointRegistrar;

import com.duxinglangzi.canal.starter.mode.CanalMessage;

import com.hz.canal.starter.configuration.CanalAutoConfigurationProperties;
import com.hz.canal.starter.configuration.CanalListenerEndpointRegistrar;
import com.hz.canal.starter.mode.CanalMessage;
import org.slf4j.Logger;

import org.slf4j.LoggerFactory;




 src/main/java/com/hz/canal/starter/factory/CanalConnectorFactory.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/factory/CanalConnectorFactory.java
@@ -1,9 +1,9 @@
package com.duxinglangzi.canal.starter.factory;

package com.hz.canal.starter.factory;


import com.alibaba.otter.canal.client.CanalConnector;

import com.alibaba.otter.canal.client.CanalConnectors;

import com.alibaba.otter.canal.protocol.exception.CanalClientException;

import com.duxinglangzi.canal.starter.configuration.CanalAutoConfigurationProperties;

import com.hz.canal.starter.configuration.CanalAutoConfigurationProperties;
import org.springframework.util.Assert;

import org.springframework.util.StringUtils;




 src/main/java/com/hz/canal/starter/factory/TransponderContainerFactory.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/factory/TransponderContainerFactory.java
@@ -1,9 +1,9 @@
package com.duxinglangzi.canal.starter.factory;

package com.hz.canal.starter.factory;


import com.alibaba.otter.canal.client.CanalConnector;

import com.duxinglangzi.canal.starter.configuration.CanalAutoConfigurationProperties;

import com.duxinglangzi.canal.starter.configuration.CanalListenerEndpointRegistrar;

import com.duxinglangzi.canal.starter.container.DmlMessageTransponderContainer;

import com.hz.canal.starter.configuration.CanalAutoConfigurationProperties;
import com.hz.canal.starter.configuration.CanalListenerEndpointRegistrar;
import com.hz.canal.starter.container.DmlMessageTransponderContainer;
import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;



import java.util.ArrayList;


 src/main/java/com/hz/canal/starter/listener/ApplicationReadyListener.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/listener/ApplicationReadyListener.java
@@ -1,4 +1,4 @@
package com.duxinglangzi.canal.starter.listener;

package com.hz.canal.starter.listener;


import org.springframework.boot.context.event.ApplicationReadyEvent;

import org.springframework.context.ApplicationListener;


 src/main/java/com/hz/canal/starter/mode/CanalMessage.java

File was renamed from src/main/java/com/duxinglangzi/canal/starter/mode/CanalMessage.java
@@ -1,4 +1,4 @@
package com.duxinglangzi.canal.starter.mode;
package com.hz.canal.starter.mode;

import com.alibaba.otter.canal.protocol.CanalEntry;


 src/main/resources/META-INF/spring-configuration-metadata.json

@@ -1,9 +1,9 @@
{

  "properties": [

    {

      "sourceType": "com.duxinglangzi.canal.starter.configuration.CanalAutoConfigurationProperties",

      "sourceType": "com.hz.canal.starter.configuration.CanalAutoConfigurationProperties",

      "name": "spring.canal.instances",

      "type": "java.util.Map<java.lang.String,com.duxinglangzi.canal.starter.configuration.CanalAutoConfigurationProperties.EndpointInstance>",

      "type": "java.util.Map<java.lang.String,com.hz.canal.starter.configuration.CanalAutoConfigurationProperties.EndpointInstance>",

      "description": "canal config "

    }

  ]


 src/main/resources/META-INF/spring.factories

@@ -1,9 +1,9 @@

# Auto Configure
# org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
# com.duxinglangzi.canal.starter.configuration.CanalAutoConfigurationProperties,\
# com.duxinglangzi.canal.starter.configuration.CanalConfigurationSelector
# CanalAutoConfigurationProperties,\
# CanalConfigurationSelector

# Application Listeners
# org.springframework.context.ApplicationListener=\
# com.duxinglangzi.canal.starter.listener.ApplicationReadyListener
# ApplicationReadyListener