chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

注销父类已经有的属性，避免super.start()调用了没有在子类初始化的同名属性

Browse Source
This commit is contained in:
dingjun
2016-02-23 10:40:42 +08:00
parent bf10b16138
commit efebbe301a
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java
View File

@@ -65,15 +65,15 @@ import com.alibaba.otter.canal.store.model.Event;
public class CanalInstanceWithManager extends AbstractCanalInstance { public class CanalInstanceWithManager extends AbstractCanalInstance {
private static final Logger logger = LoggerFactory.getLogger(CanalInstanceWithManager.class); private static final Logger logger = LoggerFactory.getLogger(CanalInstanceWithManager.class);
protected String destination; // 队列名字 //protected String destination; // 队列名字
protected String filter; // 过滤表达式 protected String filter; // 过滤表达式
protected CanalParameter parameters; // 对应参数 protected CanalParameter parameters; // 对应参数
protected CanalMetaManager metaManager; // 消费信息管理器 //protected CanalMetaManager metaManager; // 消费信息管理器
protected CanalEventStore<Event> eventStore; // 有序队列 //protected CanalEventStore<Event> eventStore; // 有序队列
protected CanalEventParser eventParser; // 解析对应的数据信息 //protected CanalEventParser eventParser; // 解析对应的数据信息
protected CanalEventSink<List<Entry>> eventSink; // 链接parse和store的桥接器 //protected CanalEventSink<List<Entry>> eventSink; // 链接parse和store的桥接器
protected CanalAlarmHandler alarmHandler; // alarm报警机制 //protected CanalAlarmHandler alarmHandler; // alarm报警机制
public CanalInstanceWithManager(Canal canal, String filter){ public CanalInstanceWithManager(Canal canal, String filter){
this.parameters = canal.getCanalParameter(); this.parameters = canal.getCanalParameter();