From 68880dd956fb6fcd41bb51d7d59f344db4567f18 Mon Sep 17 00:00:00 2001 From: wuenzhen Date: Fri, 26 Dec 2025 12:22:32 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E7=BA=BF=E7=A8=8B=E4=B8=AD=E6=96=AD?= =?UTF-8?q?=E8=AF=AF=E5=88=A4=E4=B8=BA=E8=87=B4=E5=91=BD=E5=BC=82=E5=B8=B8?= =?UTF-8?q?=E5=B9=B6=E7=9B=B4=E6=8E=A5=E5=81=9C=E6=AD=A2=E5=8F=91=E9=80=81?= =?UTF-8?q?=E7=BA=BF=E7=A8=8B=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/dianping/cat/message/io/TcpSocketSender.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/lib/java/src/main/java/com/dianping/cat/message/io/TcpSocketSender.java b/lib/java/src/main/java/com/dianping/cat/message/io/TcpSocketSender.java index bc6813e773..1684cef164 100644 --- a/lib/java/src/main/java/com/dianping/cat/message/io/TcpSocketSender.java +++ b/lib/java/src/main/java/com/dianping/cat/message/io/TcpSocketSender.java @@ -168,8 +168,8 @@ private void processMessage() { } else { try { Thread.sleep(5); - } catch (Exception e) { - active = false; + } catch (InterruptedException e) { + Thread.currentThread().interrupt(); } } } catch (Throwable t) { @@ -201,8 +201,8 @@ private void processMessage() { try { Thread.sleep(5); - } catch (Exception e) { - active = false; + } catch (InterruptedException e) { + Thread.currentThread().interrupt(); } } }