Spring Integration File channel adapter轮询文件无限次且不创建消息有效负载

Question

我正在使用入站通道适配器poling目录。但是，它一直在无限次地poling同一个文件，而不创建消息负载。

<int-file:inbound-channel-adapter id="pollDataFile"
    directory="file:////D:/Directory1"
    channel="inboundFileChannel" auto-startup="true" filter="compositeFilter">
    <int:poller default="true" fixed-rate="5000" time-unit="MILLISECONDS"/>
</int-file:inbound-channel-adapter>

<int:service-activator id="moveFileToInProgress" ref="handler" input-channel="inboundFileChannel" output-channel="filesInProcess" />

    <bean id="handler" class="com.spring.batch.util.FileCopyService"/>

    <int-file:outbound-channel-adapter
        id="filesCopyToInProcess" channel="filesInProcess"
        directory="file:////D:/InProgress"
        auto-create-directory="false" delete-source-files="true">
</int-file:outbound-channel-adapter>

<int-file:inbound-channel-adapter id="pollDataFileInProgress"
        directory="file:////D:/InProgress" prevent-duplicates="true"
        channel="filesInProcessToProcess" filter="compositeFilter">
        <int:poller default="true" fixed-rate="10000"  time-unit="MILLISECONDS"/>
    </int-file:inbound-channel-adapter>

    <int:transformer id="prepareJobLaunchRequest"
        input-channel="filesInProcessToProcess" output-channel="outboundJobRequestChannel">
        <bean class="com.spring.batch.util.FileMessageToJobRequest">
            <property name="job" ref="fileUploadJob" />
            <property name="fileParameterName" value="input.file.name" />
            <property name="beanReader" value="bean.reader" />
            <property name="beanWriter" value="bean.writer" />
            <property name="beanProcessor" value="bean.processor" />
        </bean>
</int:transformer>


<bean id="compositeFilter"
    class="org.springframework.integration.file.filters.AcceptAllFileListFilter" />

Answer 1

prevent-duplicates=“true”添加acceptonceFilelistFilter，这样就有了冲突的筛选器（全部接受和一次接受）；不会处理重复的文件名。

设置prevent-duplicates=“false”。