Spring Integration-Inbount通道适配器在读取新文件时再次发送上一个文件

Question

当入站通道适配器从输入目录读取第二个文件时，我遇到了一个问题。适配器启动如下流：适配器->通道->拆分器->通道...->数据库。

拆分器读取文件，处理每一行，然后将文件复制到另一个目录，并删除原始文件。

问题是，适配器可以像预期的那样处理第一个文件，但当它读取第二个文件时，它会再次从第一个文件发送消息（第一个文件不再在输入目录中）。

注意：第一个通道具有ActiveMQ队列。Ack本地。

配置：

<int-file:inbound-channel-adapter id="filesIn" channel="reinjectionChannel" filename-regex="reinyeccion[0-9]{8}.txt"
    directory="${input.directory.reinyeccion}" prevent-duplicates="true" />

<jms:channel id="reinjectionChannel" queue="reinjectionChannelQueue">
    <jms:interceptors>
        <int:wire-tap channel="reinjectionLoggingChannel"/>
    </jms:interceptors>
</jms:channel>

<int:splitter input-channel="reinjectionChannel" method="split" 
    output-channel="inputChannel" ref="reinjectionSplitterBean" />

<int:channel id="inputChannel" >
    <int:interceptors>
        <int:wire-tap channel="inputLoggingChannel"/>
    </int:interceptors>
</int:channel>

日志：

org.springframework.integration.handler.LoggingHandler   handleMessageInternal  INFO  (BBR) reinjectionLoggingChannel \tmp\concentrador\files\input\reinyeccion20151109.txt
org.springframework.integration.handler.LoggingHandler   handleMessageInternal  INFO  (BBR) reinjectionLoggingChannel \tmp\concentrador\files\input\reinyeccion20151108.txt

谢谢你的帮助。

Answer 1

我找到了，我需要清除拆分器返回的消息列表。