From d85794c17f41f8f75b2be0340e3f1241b1cae520 Mon Sep 17 00:00:00 2001 From: James Strachan Date: Fri, 23 Feb 2007 06:04:41 +0000 Subject: [PATCH] Applied patch from Tom Vijlbrief for AMQ-724 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@510843 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/activemq/transport/InactivityMonitor.java | 5 ++--- 1 file changed, 2 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 84d373cbb7..6c6f20b501 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 @@ -17,14 +17,13 @@ */ package org.apache.activemq.transport; -import java.io.IOException; - import org.apache.activemq.command.KeepAliveInfo; import org.apache.activemq.command.WireFormatInfo; import org.apache.activemq.thread.Scheduler; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; +import java.io.IOException; import java.util.concurrent.atomic.AtomicBoolean; /** @@ -147,8 +146,8 @@ public class InactivityMonitor extends TransportFilter { public void onException(IOException error) { if( monitorStarted.get() ) { stopMonitorThreads(); - getTransportListener().onException(error); } + getTransportListener().onException(error); }