Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix problem in message state tracker that will result on OME 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@635565 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-03-10 14:16:49 +00:00
parent 5e747b070d
commit c42c5ff976
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java
View File

@ -63,7 +63,9 @@ public class ConnectionStateTracker extends CommandVisitorAdapter {
private Map<MessageId,Message> messageCache = new LinkedHashMap<MessageId,Message>(){ private Map<MessageId,Message> messageCache = new LinkedHashMap<MessageId,Message>(){
protected boolean removeEldestEntry(Map.Entry<MessageId,Message> eldest) { protected boolean removeEldestEntry(Map.Entry<MessageId,Message> eldest) {
boolean result = currentCacheSize > maxCacheSize; boolean result = currentCacheSize > maxCacheSize;
currentCacheSize -= eldest.getValue().getSize(); if (result) {
currentCacheSize -= eldest.getValue().getSize();
}
return result; return result;
} }
}; };
@ -104,7 +106,7 @@ public class ConnectionStateTracker extends CommandVisitorAdapter {
if (trackMessages && command != null && command.isMessage()) { if (trackMessages && command != null && command.isMessage()) {
Message message = (Message) command; Message message = (Message) command;
if (message.getTransactionId()==null) { if (message.getTransactionId()==null) {
currentCacheSize+=message.getSize(); currentCacheSize = currentCacheSize + message.getSize();
} }
} }
} }