diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/router/AggregatingMessageHandler.java b/org.springframework.integration/src/main/java/org/springframework/integration/router/AggregatingMessageHandler.java
index 2036fcc231..f905df7572 100644
--- a/org.springframework.integration/src/main/java/org/springframework/integration/router/AggregatingMessageHandler.java
+++ b/org.springframework.integration/src/main/java/org/springframework/integration/router/AggregatingMessageHandler.java
@@ -87,6 +87,9 @@ public class AggregatingMessageHandler extends AbstractMessageBarrierHandler {
 			return new Message<?>[0];
 		}
 		Message<?> result = aggregator.aggregate(messages);
+		if (result.getHeader().getCorrelationId() == null) {
+			result.getHeader().setCorrelationId(correlationId);
+		}
 		return new Message<?>[] { result };
 		
 	}