You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2007/10/22 21:01:16 UTC
svn commit: r587198 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
Author: chirino
Date: Mon Oct 22 12:01:16 2007
New Revision: 587198
URL: http://svn.apache.org/viewvc?rev=587198&view=rev
Log:
Avoid deadlock described at: https://issues.apache.org/activemq/browse/AMQ-1468
Synchronization not really required once the transport errors out..
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java?rev=587198&r1=587197&r2=587198&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java Mon Oct 22 12:01:16 2007
@@ -154,9 +154,7 @@
if (monitorStarted.get()) {
stopMonitorThreads();
}
- synchronized (readChecker) {
- transportListener.onException(error);
- }
+ transportListener.onException(error);
}
private synchronized void startMonitorThreads() throws IOException {