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 | 1 +
1 files changed, 1 insertions(+), 0 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 d554cad..ff89712 100644
--- a/src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java
+++ b/src/main/java/com/duxinglangzi/canal/starter/container/DmlMessageTransponderContainer.java
@@ -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