File was renamed from src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerEndpointRegistrar.java |
| | |
| | | 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;
|