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();
             }
         }
     }