Spring Aggregator Annotation没有expireGroupUponCompletion和persistenceStore作为输入

2024年1月11日 283次阅读

我最近转到
Spring启动并开始将所有XML转换为
Java Configs. @Aggregate注释没有expireGroupUponCompletion和persistenceStore作为输入.还有其他方法我们可以指定这些东西吗？ 最佳答案

Is there any other way we can specify these things?

使用Spring Integration Java DSL：

.aggregate(a -> a.expireGroupsUponCompletion(true)
                 .sendPartialResultOnExpiry(true)
                 .messageStore(messageStore(), null)

第二个空参数意味着我们对某些端点定制不感兴趣,只是依赖于默认状态.我们保留了该语法以避免Lambda参数的显式类型：

.aggregate((AggregatorSpec a) -> a.expireGroupsUponCompletion(true)
                 .sendPartialResultOnExpiry(true)
                 .messageStore(messageStore())
点赞