Repository: activemq-artemis Updated Branches: refs/heads/master 1e8eee0fb -> 24cb5458f
https://issues.apache.org/jira/browse/ARTEMIS-320 fixing memory leak Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/d1c1c50a Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/d1c1c50a Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/d1c1c50a Branch: refs/heads/master Commit: d1c1c50aa2b218c5c2a514d63b57f3b4bf89de57 Parents: 1e8eee0 Author: Clebert Suconic <[email protected]> Authored: Fri Jan 1 13:39:21 2016 -0500 Committer: Clebert Suconic <[email protected]> Committed: Fri Jan 1 13:39:56 2016 -0500 ---------------------------------------------------------------------- .../artemis/core/remoting/impl/netty/NettyConnection.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/d1c1c50a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java ---------------------------------------------------------------------- diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java index 62943ca..cc3b65a 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java @@ -103,7 +103,9 @@ public class NettyConnection implements Connection { @Override public boolean isWritable(ReadyListener callback) { synchronized (readyListeners) { - readyListeners.push(callback); + if (!ready) { + readyListeners.push(callback); + } return ready; }
