Spring Integration aggregator when last record过滤器

Question

我们有一个Spring Integration项目，其中一个大的输入文件被拆分成许多单独的文件，然后使用Spring Integration聚合器聚合在一起。

管道中有许多过滤器可以过滤掉不需要的单个文件。我们跟踪为每个相关输入文件过滤的文件数。我们的@ReleaseStrategy检查我们是否收到了单个文件的数量减去过滤的单个文件的数量。

如果要处理的最后一个文件在到达我们的ReleaseStrategy之前被过滤，会发生什么？ReleaseStrategy是为每个到达它的单独文件调用的，如果最后一个单独的文件被过滤了，我就不会再被轮询，但我也希望Spring已经预见到了这个用例，并为它做了一些非黑客的配置，仍然为我提供了@Aggregator事件。如果我超时了，或者如果我让所有的筛选器点检查它们是否是最后一个文件，我就不会得到@Aggregator事件。

谢谢!

Answer 1

Split-filter-aggregate模式的正确答案是在聚合器bean上设置以下属性。

send-partial-result-on-expiry="true"
group-timeout="5000"

这两个属性协同工作来处理与所描述的情况完全相同的情况，在这种情况下，我们的ReleaseStrategy永远不会与最后一条记录一起调用，因为最后一条记录已被过滤。一旦超时，这些设置将导致任何排队的内容被释放。

超时是“静默期”，如果在超时期间没有接收到给定CorrelationStrategy的消息，则聚合释放。收到的每条消息都会重置超时。参见第(21)节：http://docs.spring.io/spring-integration/reference/htmlsingle/