Author: clebert.suconic(a)jboss.com Date: 2011-11-22 14:31:59 -0500 (Tue, 22 Nov 2011) New Revision: 11741 Modified: branches/Branch_2_2_AS7/src/main/org/hornetq/core/protocol/stomp/StompConnection.java branches/Branch_2_2_AS7/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java Log: avoiding dead locks through stomp / close session Modified: branches/Branch_2_2_AS7/src/main/org/hornetq/core/protocol/stomp/StompConnection.java =================================================================== --- branches/Branch_2_2_AS7/src/main/org/hornetq/core/protocol/stomp/StompConnection.java 2011-11-22 17:23:39 UTC (rev 11740) +++ branches/Branch_2_2_AS7/src/main/org/hornetq/core/protocol/stomp/StompConnection.java 2011-11-22 19:31:59 UTC (rev 11741) @@ -17,6 +17,7 @@ import java.util.Collections; import java.util.List; import java.util.concurrent.CopyOnWriteArrayList; +import java.util.concurrent.Executor; import org.hornetq.api.core.HornetQBuffer; import org.hornetq.api.core.HornetQBuffers; @@ -66,6 +67,8 @@ private final Object failLock = new Object(); + private final Executor executor; + private volatile boolean dataReceived; public StompDecoder getDecoder() @@ -73,7 +76,7 @@ return decoder; } - StompConnection(final Acceptor acceptorUsed, final Connection transportConnection, final StompProtocolManager manager) + StompConnection(final Acceptor acceptorUsed, final Connection transportConnection, final StompProtocolManager manager, final Executor executor) { this.transportConnection = transportConnection; @@ -82,6 +85,8 @@ this.creationTime = System.currentTimeMillis(); this.acceptorUsed = acceptorUsed; + + this.executor = executor; } public void addFailureListener(final FailureListener listener) @@ -322,7 +327,6 @@ private void callFailureListeners(final HornetQException me) { final List<FailureListener> listenersClone = new ArrayList<FailureListener>(failureListeners); - for (final FailureListener listener : listenersClone) { try @@ -343,20 +347,26 @@ { final List<CloseListener> listenersClone = new ArrayList<CloseListener>(closeListeners); - for (final CloseListener listener : listenersClone) - { - try + // avoiding a dead lock + executor.execute(new Runnable(){ + public void run() { - listener.connectionClosed(); + for (final CloseListener listener : listenersClone) + { + try + { + listener.connectionClosed(); + } + catch (final Throwable t) + { + // Failure of one listener to execute shouldn't prevent others + // from + // executing + log.error("Failed to execute failure listener", t); + } + } } - catch (final Throwable t) - { - // Failure of one listener to execute shouldn't prevent others - // from - // executing - log.error("Failed to execute failure listener", t); - } - } + }); } } Modified: branches/Branch_2_2_AS7/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java =================================================================== --- branches/Branch_2_2_AS7/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java 2011-11-22 17:23:39 UTC (rev 11740) +++ branches/Branch_2_2_AS7/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java 2011-11-22 19:31:59 UTC (rev 11741) @@ -120,7 +120,7 @@ public ConnectionEntry createConnectionEntry(final Acceptor acceptorUsed, final Connection connection) { - StompConnection conn = new StompConnection(acceptorUsed, connection, this); + StompConnection conn = new StompConnection(acceptorUsed, connection, this, server.getExecutorFactory().getExecutor()); // Note that STOMP has no heartbeat, so if connection ttl is non zero, data must continue to be sent or connection // will be timed out and closed!