Skip adding aggregates when the flow is completed

wso2 · Dec 6, 2024 · 94b201f · 94b201f
1 parent 0ccc7e5
commit 94b201f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/Aggregate.java b/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/Aggregate.java
@@ -115,6 +115,9 @@ public Aggregate(SynapseEnvironment synEnv, String corelation, long timeoutMilli
      */
     public synchronized boolean addMessage(MessageContext synCtx) {
         if (maxCount <= 0 || (maxCount > 0 && messages.size() < maxCount)) {
+            if (messages == null) {
+                return false;
+            }
             messages.add(synCtx);
             return true;
         } else {