From 039d193cfd725508a082f98eb6eaac062ce2cbad Mon Sep 17 00:00:00 2001
From: Sanoj Punchihewa <sanoj@wso2.com>
Date: Mon, 16 Dec 2024 11:27:46 +0530
Subject: [PATCH] Fix erroneous clearing of active aggregate map in Aggregate
 mediator

---
 .../synapse/mediators/eip/aggregator/AggregateMediator.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/AggregateMediator.java b/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/AggregateMediator.java
index 6444bd5d4a..54ce14e6c8 100755
--- a/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/AggregateMediator.java
+++ b/modules/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 {