| 提交 | 用户 | age | ||
| 0b055a | 1 | package com.hz.canal.starter.annotation; |
| R | 2 | |
| 3 | ||
| 4 | import com.alibaba.otter.canal.protocol.CanalEntry; | |
| 5 | import org.springframework.core.annotation.AliasFor; | |
| 6 | ||
| 7 | import java.lang.annotation.ElementType; | |
| 8 | import java.lang.annotation.Retention; | |
| 9 | import java.lang.annotation.RetentionPolicy; | |
| 10 | import java.lang.annotation.Target; | |
| 11 | ||
| 12 | /** | |
| 13 | * @author wuqiong 2022/4/11 | |
| 14 | */ | |
| 15 | @Target(ElementType.METHOD) | |
| 16 | @Retention(RetentionPolicy.RUNTIME) | |
| 17 | @CanalListener(eventType = CanalEntry.EventType.INSERT) | |
| 18 | public @interface CanalInsertListener { | |
| 19 | ||
| 20 | @AliasFor(annotation = CanalListener.class) | |
| 21 | String destination(); | |
| 22 | ||
| 23 | @AliasFor(annotation = CanalListener.class) | |
| 24 | String database(); | |
| 25 | ||
| 26 | @AliasFor(annotation = CanalListener.class) | |
| 27 | String[] table(); | |
| 28 | ||
| 29 | } | |
