From cfbb3c852a9bdfffd05d337a08b9d2bdf70e502f Mon Sep 17 00:00:00 2001
From: James Strachan <jstrachan@apache.org>
Date: Fri, 17 Mar 2006 09:15:38 +0000
Subject: [PATCH] fix for AMQ-627 to always catch and deal with interupted
 exceptions

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@386586 13f79535-47bb-0310-9956-ffa450edef68
---
 .../main/java/org/apache/activemq/ActiveMQQueueBrowser.java | 6 ++++--
 .../org/apache/activemq/transport/tcp/ResponseHolder.java   | 2 +-
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueBrowser.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueBrowser.java
index d2d0f7719d..fa3c7e44ac 100755
--- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueBrowser.java
+++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueBrowser.java
@@ -229,10 +229,12 @@ public class ActiveMQQueueBrowser implements
      */
     protected void waitForMessage() {
         try {
-            synchronized (semaphore ) {
+            synchronized (semaphore) {
                 semaphore.wait(2000);
             }
-        } catch (InterruptedException e) {
+        }
+        catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
         }
     }
     
diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/tcp/ResponseHolder.java b/activemq-core/src/main/java/org/apache/activemq/transport/tcp/ResponseHolder.java
index 6f1d1ca417..77869f23ff 100755
--- a/activemq-core/src/main/java/org/apache/activemq/transport/tcp/ResponseHolder.java
+++ b/activemq-core/src/main/java/org/apache/activemq/transport/tcp/ResponseHolder.java
@@ -69,7 +69,7 @@ public class ResponseHolder {
                     lock.wait(timeout);
                 }
                 catch (InterruptedException e) {
-                    e.printStackTrace();
+                    Thread.currentThread().interrupt();
                 }
             }
         }