You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2008/09/08 09:17:12 UTC
svn commit: r693003 -
/servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-eip/src/main/java/org/apache/servicemix/eip/support/AbstractAggregator.java
Author: gnodet
Date: Mon Sep 8 00:17:12 2008
New Revision: 693003
URL: http://svn.apache.org/viewvc?rev=693003&view=rev
Log:
SM-1518: Aggregator keeps a list of closed aggregations causing a slight memory leak
Modified:
servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-eip/src/main/java/org/apache/servicemix/eip/support/AbstractAggregator.java
Modified: servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-eip/src/main/java/org/apache/servicemix/eip/support/AbstractAggregator.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-eip/src/main/java/org/apache/servicemix/eip/support/AbstractAggregator.java?rev=693003&r1=693002&r2=693003&view=diff
==============================================================================
--- servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-eip/src/main/java/org/apache/servicemix/eip/support/AbstractAggregator.java (original)
+++ servicemix/smx3/branches/servicemix-3.2/deployables/serviceengines/servicemix-eip/src/main/java/org/apache/servicemix/eip/support/AbstractAggregator.java Mon Sep 8 00:17:12 2008
@@ -306,9 +306,9 @@
*/
protected boolean isAggregationClosed(String correlationId) throws Exception {
// TODO: implement this using a persistent / cached behavior
- Object data = store.load(correlationId);
+ Object data = closedAggregates.load(correlationId);
if (data != null) {
- store.store(correlationId, data);
+ closedAggregates.store(correlationId, data);
}
return data != null;
}