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;
     }