修改启用方式为EnableCanalListener注解 修改重试次数瑕疵

duxinglangzi

2022-08-04 a8f947d2bc621051821e0cc57335aa6ca1776a8e

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

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

            initConnect();

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

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

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

        }).start();

        setRunning(true);

    }