入站适配器跳过消息

Question

这就是我的配置

<int-file:inbound-channel-adapter id="files" directory="${lz.dir.${ft}}">
    <int:poller fixed-delay="3000" max-messages-per-poll="3"  />
</int-file:inbound-channel-adapter>

<int:bridge input-channel="files" output-channel="sourceFiles" />

<int:channel id="sourceFiles">
    <int:dispatcher task-executor="executor" />
</int:channel>

<int:service-activator  input-channel="sourceFiles" 
                        ref="moveToSource" 
                        method="move" />

<int:aggregator id="filesBuffered" 
                input-channel="sourceFiles"
                output-channel="stagedFiles"
                release-strategy-expression="size() == 10" 
                correlation-strategy-expression="'mes-group'" 
                expire-groups-upon-completion="true" 
                />

<int:channel id="stagedFiles" />

<int:service-activator  input-channel="stagedFiles"
                        ref="moveToStage"   
                        method="move" />

<task:executor id="executor" pool-size="5" queue-capacity="0" rejection-policy="CALLER_RUNS" />

这个想法是每3秒轮询一个目录，并根据通道向调度程序发送3条消息，以允许异步执行。然后根据消息数量聚合消息，然后发送到下一个服务激活器。第一个服务激活器将文件放在源目录中，第二个服务激活器获取聚合列表以将这些文件移动到暂存目录。

似乎发生的情况是，源文件夹跳过了一些文件，但临时文件夹确实获取了所有文件。我的猜测是，轮询器将消息发送到dispatcher通道，但当其线程池变满时，它会忽略文件，但聚合器仍会以某种方式获取所有文件。几乎就像dispatcher通道在线程池限制达到后跳过它接收的文件的第一个service activator步骤，但这些文件仍被传递到下一个通道，因此它们最终仍由第二个service activator处理。

我想做的是让轮询器重新发送被调度程序拒绝的文件。任何想法都将不胜感激。

谢啦

Answer 1

对不起，我不明白你的描述，但根据您的配置，它看起来像：

1. 源文件通道是点对点通道。因此，一次只有一个订阅者可以从该通道获取消息

如果这不是您的案例，请提供正确的配置或解释您的用例。现在它很混乱，抱歉。

HTH