renxue
2022-10-24 0b055a3f554da3a934e79e88c4781705cbab5a21
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,41 +1,41 @@
package com.duxinglangzi.canal.starter.annotation;
import com.alibaba.otter.canal.protocol.CanalEntry;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
 * @author wuqiong 2022/4/11
 */
@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface CanalListener {
    /**
     * 如果未进行配置,则使用配置文件里全部 destination
     */
    String destination() default "";
    /**
     * 数据库名
     */
    String database() default "";
    /**
     * 数据表名
     */
    String[] table() default "";
    /**
     * 数据变动类型,此处请注意,默认不包含 DDL
     */
    CanalEntry.EventType[] eventType();
}
package com.hz.canal.starter.annotation;
import com.alibaba.otter.canal.protocol.CanalEntry;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/**
 * @author wuqiong 2022/4/11
 */
@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface CanalListener {
    /**
     * 如果未进行配置,则使用配置文件里全部 destination
     */
    String destination() default "";
    /**
     * 数据库名
     */
    String database() default "";
    /**
     * 数据表名
     */
    String[] table() default "";
    /**
     * 数据变动类型,此处请注意,默认不包含 DDL
     */
    CanalEntry.EventType[] eventType();
}