Fix erroneous clearing of active aggregate map in Aggregate mediator

wso2 · Dec 16, 2024 · 039d193 · 039d193
1 parent 16bd786
commit 039d193
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...les/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/AggregateMediator.java b/...les/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/AggregateMediator.java
@@ -830,7 +830,7 @@ public void setComponentStatisticsId(ArtifactHolder holder) {
 
     private void handleException(Aggregate aggregate, String msg, Exception exception, MessageContext msgContext) {
         aggregate.clear();
-        activeAggregates.clear();
+        activeAggregates.remove(aggregate.getCorrelation());
         if (exception != null) {
             super.handleException(msg, exception, msgContext);
         } else {