package com.duxinglangzi.canal.starter.annotation;
|
|
|
import com.alibaba.otter.canal.protocol.CanalEntry;
|
import org.springframework.core.annotation.AliasFor;
|
|
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)
|
@Retention(RetentionPolicy.RUNTIME)
|
@CanalListener(eventType = CanalEntry.EventType.INSERT)
|
public @interface CanalInsertListener {
|
|
@AliasFor(annotation = CanalListener.class)
|
String destination();
|
|
@AliasFor(annotation = CanalListener.class)
|
String database();
|
|
@AliasFor(annotation = CanalListener.class)
|
String[] table();
|
|
}
|
