Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-09 03:25:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

Apply fix for https://issues.apache.org/activemq/browse/AMQ-1852

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@675463 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-07-10 07:10:06 +00:00
parent f4012c5098
commit e233801bb3
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
View File

@ -186,7 +186,12 @@ public class TcpTransport extends TransportThreadSupport implements Transport, S
} catch (IOException e) { } catch (IOException e) {
stoppedLatch.get().countDown(); stoppedLatch.get().countDown();
onException(e); 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(); stoppedLatch.get().countDown();
} }
} }