Fix releasePartialSequences value propagation for SequenceSizeReleaseStrategy.

Fixes: spring-projects#10003
Issue Link: spring-projects#10003

Signed-off-by: Jiandong Ma <[email protected]>

Author: mjd507

spring-integration-core/src/main/java/org/springframework/integration/aggregator/AbstractCorrelatingMessageHandler.java

@@ -299,7 +299,7 @@ public void setMinimumTimeoutForEmptyGroups(long minimumTimeoutForEmptyGroups) {
 	 */
 	public void setReleasePartialSequences(boolean releasePartialSequences) {
 		if (!this.releaseStrategySet && releasePartialSequences) {
-			setReleaseStrategy(new SequenceSizeReleaseStrategy());
+			setReleaseStrategy(new SequenceSizeReleaseStrategy(releasePartialSequences));
 		}
 		this.releasePartialSequences = releasePartialSequences;
 	}

spring-integration-core/src/test/java/org/springframework/integration/aggregator/AggregatorTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2024 the original author or authors.
+ * Copyright 2002-2025 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -129,7 +129,6 @@ public void testAggPerf() throws InterruptedException, ExecutionException, Timeo
 	}
 
 	@Test
-	@Disabled("Time sensitive")
 	public void testAggPerfDefaultPartial() throws InterruptedException, ExecutionException, TimeoutException {
 		AggregatingMessageHandler handler = new AggregatingMessageHandler(new DefaultAggregatingMessageGroupProcessor());
 		handler.setCorrelationStrategy(message -> "foo");
@@ -152,28 +151,30 @@ public void testAggPerfDefaultPartial() throws InterruptedException, ExecutionEx
 		store.setMessageGroupFactory(messageGroupFactory);
 
 		handler.setMessageStore(store);
+		handler.setBeanFactory(mock(BeanFactory.class));
+		handler.afterPropertiesSet();
 
 		StopWatch stopwatch = new StopWatch();
 		stopwatch.start();
-		for (int i = 0; i < 120000; i++) {
-			if (i % 10000 == 0) {
+		for (int i = 0; i < 1200; i++) {
+			if (i % 100 == 0) {
 				stopwatch.stop();
 				logger.warn("Sent " + i + " in " + stopwatch.getTotalTimeSeconds() +
-						" (10k in " + stopwatch.lastTaskInfo().getTimeMillis() + "ms)");
+						" (100 in " + stopwatch.lastTaskInfo().getTimeMillis() + "ms)");
 				stopwatch.start();
 			}
 			handler.handleMessage(MessageBuilder.withPayload("foo")
-					.setSequenceSize(120000)
+					.setSequenceSize(1200)
 					.setSequenceNumber(i + 1)
 					.build());
 		}
 		stopwatch.stop();
-		logger.warn("Sent " + 120000 + " in " + stopwatch.getTotalTimeSeconds() +
+		logger.warn("Sent " + 1200 + " in " + stopwatch.getTotalTimeSeconds() +
 				" (10k in " + stopwatch.lastTaskInfo().getTimeMillis() + "ms)");
 
 		Collection<?> result = resultFuture.get(10, TimeUnit.SECONDS);
 		assertThat(result).isNotNull();
-		assertThat(result.size()).isEqualTo(120000);
+		assertThat(result.size()).isEqualTo(1);
 		assertThat(stopwatch.getTotalTimeSeconds()).isLessThan(60.0); // actually < 2.0, was many minutes
 	}