activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r649658 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
Date Fri, 18 Apr 2008 19:12:11 GMT
Author: chirino
Date: Fri Apr 18 12:12:07 2008
New Revision: 649658

URL: http://svn.apache.org/viewvc?rev=649658&view=rev
Log:
Bad logic was not propagating the transport exception up.

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

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java?rev=649658&r1=649657&r2=649658&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
Fri Apr 18 12:12:07 2008
@@ -239,9 +239,9 @@
     }
 
     public void onException(IOException error) {
-        if (!failed.compareAndSet(false,true)) {
-    		stopMonitorThreads();
-    		transportListener.onException(error);
+        if (failed.compareAndSet(false, true)) {
+            stopMonitorThreads();
+            transportListener.onException(error);
         }
     }    	
 



Mime
View raw message