修改了listener方法的参数

duxinglangzi

2022-08-15 c83c1b4ee7ff9c01a7a67855863c281589f39c72

 src/main/java/com/duxinglangzi/canal/starter/container/AbstractCanalTransponderContainer.java

@@ -10,6 +10,7 @@


/**

 * 抽象的canal transponder ,实现SmartLifecycle接口,声明周期由spring进行管理

 *

 * @author wuqiong 2022/4/11

 */

public abstract class AbstractCanalTransponderContainer implements SmartLifecycle {

@@ -21,7 +22,9 @@
                    CanalEntry.EntryType.HEARTBEAT);



    protected abstract void doStart();



    protected abstract void initConnect();



    protected abstract void disconnect();





@@ -33,7 +36,7 @@
                sleep(5L * SLEEP_TIME_MILLI_SECONDS);

            initConnect();

            while (isRunning() && !Thread.currentThread().isInterrupted()) doStart();

            disconnect(); // 线程被终止或者容器已经停止

            disconnect(); // 线程被终止或者容器已经停止,需要关闭连接

        }).start();

        setRunning(true);

    }

@@ -55,7 +58,7 @@
        return isRunning;

    }



    protected void setRunning(boolean bool){

    protected void setRunning(boolean bool) {

        isRunning = bool;

    }