增加关闭

duxinglangzi

2022-04-24 fa654ac361fcc231bc389ca446f78d501c7060c8

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

@@ -12,8 +12,8 @@
import java.util.*;



/**

 * DML 数据拉取、解析

 * @author wuqiong 2022/4/11

 * @description

 */

public class DmlMessageTransponderContainer extends AbstractCanalTransponderContainer {



@@ -48,6 +48,7 @@
                                "thread interrupt , current connector host: {} , port: {} ",

                        endpointInstance.getHost(), endpointInstance.getPort());

                Thread.currentThread().interrupt();

                connector.disconnect();

            } else {

                sleep(endpointInstance.getAcquireInterval());

            }