From e233801bb38a360b2a473846b75168a95a599270 Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Thu, 10 Jul 2008 07:10:06 +0000 Subject: [PATCH] Apply fix for https://issues.apache.org/activemq/browse/AMQ-1852 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@675463 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/activemq/transport/tcp/TcpTransport.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java b/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java index a15bf463e1..5057654987 100755 --- a/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java +++ b/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java @@ -186,7 +186,12 @@ public class TcpTransport extends TransportThreadSupport implements Transport, S } catch (IOException e) { stoppedLatch.get().countDown(); onException(e); - } finally { + } catch (Throwable e){ + stoppedLatch.get().countDown(); + IOException ioe=new IOException("Unexpected error occured"); + ioe.initCause(e); + onException(ioe); + }finally { stoppedLatch.get().countDown(); } }