From c382b5048d6780bb0a2642ad9fdadc840b933a90 Mon Sep 17 00:00:00 2001
From: "Hiram R. Chirino" <chirino@apache.org>
Date: Fri, 18 Apr 2008 19:12:07 +0000
Subject: [PATCH] Bad logic was not propagating the transport exception up.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@649658 13f79535-47bb-0310-9956-ffa450edef68
---
 .../org/apache/activemq/transport/InactivityMonitor.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java b/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
index 0a999852eb..0785074d19 100755
--- a/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
+++ b/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
@@ -239,9 +239,9 @@ public class InactivityMonitor extends TransportFilter {
     }
 
     public void onException(IOException error) {
-        if (!failed.compareAndSet(false,true)) {
-    		stopMonitorThreads();
-    		transportListener.onException(error);
+        if (failed.compareAndSet(false, true)) {
+            stopMonitorThreads();
+            transportListener.onException(error);
         }
     }