activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r675463 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
Date Thu, 10 Jul 2008 07:10:07 GMT
Author: rajdavies
Date: Thu Jul 10 00:10:06 2008
New Revision: 675463

URL: http://svn.apache.org/viewvc?rev=675463&view=rev
Log:
Apply fix for https://issues.apache.org/activemq/browse/AMQ-1852

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java?rev=675463&r1=675462&r2=675463&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java
Thu Jul 10 00:10:06 2008
@@ -186,7 +186,12 @@
         } 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();
         }
     }



Mime
View raw message