activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r921822 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java
Date Thu, 11 Mar 2010 12:20:10 GMT
Author: rajdavies
Date: Thu Mar 11 12:20:10 2010
New Revision: 921822

URL: http://svn.apache.org/viewvc?rev=921822&view=rev
Log:
Applied patch for https://issues.apache.org/activemq/browse/AMQ-2191

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java?rev=921822&r1=921821&r2=921822&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java
Thu Mar 11 12:20:10 2010
@@ -17,6 +17,7 @@
 package org.apache.activemq.transport.vm;
 
 import java.io.IOException;
+import java.io.InterruptedIOException;
 import java.net.URI;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.atomic.AtomicBoolean;
@@ -100,7 +101,9 @@ public class VMTransport implements Tran
             }
             
         } catch (InterruptedException e) {
-            throw IOExceptionSupport.create(e);
+            InterruptedIOException iioe = new InterruptedIOException(e.getMessage());
+            iioe.initCause(e);
+            throw iioe;
         } finally {
             // Allow the peer to change state again...
             peer.enqueueValve.decrement();



Mime
View raw message