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 67133a5c7c..dfb2f55b9b 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 @@ -154,9 +154,7 @@ public class InactivityMonitor extends TransportFilter { if (monitorStarted.get()) { stopMonitorThreads(); } - synchronized (readChecker) { - transportListener.onException(error); - } + transportListener.onException(error); } private synchronized void startMonitorThreads() throws IOException {