From efebbe301a4929e36928e62bc76af4b2d1d49c4e Mon Sep 17 00:00:00 2001 From: dingjun Date: Tue, 23 Feb 2016 10:40:42 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B3=A8=E9=94=80=E7=88=B6=E7=B1=BB=E5=B7=B2?= =?UTF-8?q?=E7=BB=8F=E6=9C=89=E7=9A=84=E5=B1=9E=E6=80=A7=EF=BC=8C=E9=81=BF?= =?UTF-8?q?=E5=85=8Dsuper.start()=E8=B0=83=E7=94=A8=E4=BA=86=E6=B2=A1?= =?UTF-8?q?=E6=9C=89=E5=9C=A8=E5=AD=90=E7=B1=BB=E5=88=9D=E5=A7=8B=E5=8C=96?= =?UTF-8?q?=E7=9A=84=E5=90=8C=E5=90=8D=E5=B1=9E=E6=80=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../instance/manager/CanalInstanceWithManager.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java b/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java index 9005c73d..4fdf374e 100644 --- a/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java +++ b/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java @@ -65,15 +65,15 @@ import com.alibaba.otter.canal.store.model.Event; public class CanalInstanceWithManager extends AbstractCanalInstance { private static final Logger logger = LoggerFactory.getLogger(CanalInstanceWithManager.class); - protected String destination; // 队列名字 + //protected String destination; // 队列名字 protected String filter; // 过滤表达式 protected CanalParameter parameters; // 对应参数 - protected CanalMetaManager metaManager; // 消费信息管理器 - protected CanalEventStore eventStore; // 有序队列 + //protected CanalMetaManager metaManager; // 消费信息管理器 + //protected CanalEventStore eventStore; // 有序队列 - protected CanalEventParser eventParser; // 解析对应的数据信息 - protected CanalEventSink> eventSink; // 链接parse和store的桥接器 - protected CanalAlarmHandler alarmHandler; // alarm报警机制 + //protected CanalEventParser eventParser; // 解析对应的数据信息 + //protected CanalEventSink> eventSink; // 链接parse和store的桥接器 + //protected CanalAlarmHandler alarmHandler; // alarm报警机制 public CanalInstanceWithManager(Canal canal, String filter){ this.parameters = canal.getCanalParameter();