From fa654ac361fcc231bc389ca446f78d501c7060c8 Mon Sep 17 00:00:00 2001
From: duxinglangzi <871364441@qq.com>
Date: 星期日, 24 四月 2022 15:35:38 +0800
Subject: [PATCH] 增加关闭
---
src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java | 3 ++-
1 files changed, 2 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java b/src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java
index dd426aa..ff89712 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java
+++ b/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());
}
--
Gitblit v1.8.0