mirror of https://github.com/apache/activemq.git
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
This commit is contained in:
parent
b88db246b5
commit
d85794c17f
|
@ -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);
|
||||
}
|
||||
|
||||
|
||||
|
|
Loading…
Reference in New Issue