duxinglangzi
2022-04-25 92920274207200239e3bcee629a469e2685eebdd
src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java
@@ -35,6 +35,11 @@
    }
    public void disconnect(){
        // 关闭连接
        connector.disconnect();
    }
    public void doStart() {
        Message message = null;
@@ -48,7 +53,7 @@
                                "thread interrupt , current connector host: {} , port: {} ",
                        endpointInstance.getHost(), endpointInstance.getPort());
                Thread.currentThread().interrupt();
                connector.disconnect();
                disconnect();
            } else {
                sleep(endpointInstance.getAcquireInterval());
            }