Spring-集成聚合器不能正常工作。

@Configuration
@EnableIntegration
public class AggregatorConfig {

    @Bean
    public MessageChannel inputChannel() {
        return new DirectChannel();
    }

    @Bean
    public MessageChannel outputChannel() {
        return new DirectChannel();
    }

    @Bean
    public AggregatorFactoryBean aggregator() {
        AggregatorFactoryBean aggregatorFactoryBean = new AggregatorFactoryBean();
        aggregatorFactoryBean.setCorrelationStrategy(message -> message.getHeaders().get("correlationId"));
        aggregatorFactoryBean.setReleaseStrategy(group -> group.size() >= 3); // 当收到3条消息时释放
        aggregatorFactoryBean.setExpireGroupsUponCompletion(true);
        aggregatorFactoryBean.setSendPartialResultOnExpiry(true);
        return aggregatorFactoryBean;
    }

    @Bean
    public IntegrationFlow integrationFlow() {
        return IntegrationFlows.from(inputChannel())
                .aggregate(aggregator())
                .channel(outputChannel())
                .get();
    }
}