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,9 @@ public void setMinimumTimeoutForEmptyGroups(long minimumTimeoutForEmptyGroups) {
 	 */
 	public void setReleasePartialSequences(boolean releasePartialSequences) {
 		if (!this.releaseStrategySet && releasePartialSequences) {
-			setReleaseStrategy(new SequenceSizeReleaseStrategy());
+			SequenceSizeReleaseStrategy sequenceSizeReleaseStrategy = new SequenceSizeReleaseStrategy();
+			sequenceSizeReleaseStrategy.setReleasePartialSequences(releasePartialSequences);
+			setReleaseStrategy(sequenceSizeReleaseStrategy);
 		}
 		this.releasePartialSequences = releasePartialSequences;
 	}
@@ -415,14 +417,6 @@ protected void onInit() {
 			}
 		}
 
-		if (this.releasePartialSequences) {
-			Assert.isInstanceOf(SequenceSizeReleaseStrategy.class, this.releaseStrategy, () ->
-					"Release strategy of type [" + this.releaseStrategy.getClass().getSimpleName() +
-							"] cannot release partial sequences. Use a SequenceSizeReleaseStrategy instead.");
-			((SequenceSizeReleaseStrategy) this.releaseStrategy)
-					.setReleasePartialSequences(this.releasePartialSequences);
-		}
-
 		if (this.evaluationContext == null) {
 			this.evaluationContext = ExpressionUtils.createStandardEvaluationContext(getBeanFactory());
 		}

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.
@@ -152,6 +152,8 @@ 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();
@@ -173,7 +175,7 @@ public void testAggPerfDefaultPartial() throws InterruptedException, ExecutionEx
 
 		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
 	}