参考手册谈到了如何在XML中设置它,我看到@Aggregator的高级配置的Jira issue已经完成,但没有看到这些高级属性。那么如果使用注解,如何设置expire group呢?
发布于 2018-07-14 03:15:18
根据JIRA的票证在Reference Manual里确实有一个样本
@ServiceActivator(inputChannel = "aggregatorChannel")
@Bean
public MessageHandler aggregator(MessageGroupStore jdbcMessageGroupStore) {
AggregatingMessageHandler aggregator =
new AggregatingMessageHandler(new DefaultAggregatingMessageGroupProcessor(),
jdbcMessageGroupStore);
aggregator.setOutputChannel(resultsChannel());
aggregator.setGroupTimeoutExpression(new ValueExpression<>(500L));
aggregator.setTaskScheduler(this.taskScheduler);
return aggregator;
}在这个问题上有一个明确的说明:
Aggregator组件的
注释配置(
@Aggregator和其他)只涵盖了简单的用例,其中大多数默认选项就足够了。如果需要使用注记配置对这些选项进行更多控制,请考虑对AggregatingMessageHandler使用@Bean定义,并将其@Bean方法标记为@ServiceActivator
甚至更好地使用这个:
AggregatorFactoryBean从4.2版开始可用,以简化AggregatingMessageHandler的
配置。
对我来说所有的东西都在文档里了。遗漏了什么吗?
我的意思是AggregatorFactoryBean有一个你需要的选项:
public void setExpireGroupsUponCompletion(Boolean expireGroupsUponCompletion) {这还不够吗?
https://stackoverflow.com/questions/51330919
复制相似问题