activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r1102018 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
Date Wed, 11 May 2011 18:51:54 GMT
Author: gtully
Date: Wed May 11 18:51:54 2011
New Revision: 1102018

URL: http://svn.apache.org/viewvc?rev=1102018&view=rev
Log:
https://issues.apache.org/jira/browse/AMQ-3316 - Memory leak in ConnectionStateTracker with
MessagePull objects. Patch applied with thanks, good catch\!

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java?rev=1102018&r1=1102017&r2=1102018&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
Wed May 11 18:51:54 2011
@@ -78,6 +78,8 @@ public class ConnectionStateTracker exte
             if (result) {
                 if (eldest.getValue() instanceof Message) {
                     currentCacheSize -= ((Message)eldest.getValue()).getSize();
+                } else if (eldest.getValue() instance of MessagePull) {
+                    currentCacheSize -= 400;
                 }
             }
             return result;



Mime
View raw message