activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/2] activemq-artemis git commit: https://issues.apache.org/jira/browse/ARTEMIS-320 fixing memory leak
Date Sat, 02 Jan 2016 00:55:22 GMT
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 <clebertsuconic@apache.org>
Authored: Fri Jan 1 13:39:21 2016 -0500
Committer: Clebert Suconic <clebertsuconic@apache.org>
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;
       }


Mime
View raw message