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 dfe6c03e50..695341562e 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 @@ -105,9 +105,7 @@ public class InactivityMonitor extends TransportFilter { // TODO: use a thread pool for this.. Thread thread = new Thread("ActiveMQ: Inactivity Handler: "+next.getRemoteAddress()) { public void run() { - synchronized (readChecker) { onException(new InactivityIOException("Channel was inactive for too long: "+next.getRemoteAddress())); - } }; }; thread.setDaemon(true);