duxinglangzi
2022-04-25 92920274207200239e3bcee629a469e2685eebdd
src/main/java/com/duxinglangzi/canal/starter/container/AbstractCanalTransponderContainer.java
@@ -22,6 +22,7 @@
    protected abstract void doStart();
    protected abstract void initConnect();
    protected abstract void disconnect();
    @Override
@@ -32,6 +33,7 @@
                sleep(5L * SLEEP_TIME_MILLI_SECONDS);
            initConnect();
            while (isRunning() && !Thread.currentThread().isInterrupted()) doStart();
            disconnect(); // 线程被终止或者容器已经停止
        }).start();
        setRunning(true);
    }