Spring統合ファイルインバウンドアダプタを使用してファイルを順番に処理する方法

Question

ソースディレクトリからファイルを読み込み、順番に（1つずつ）処理する必要があります。私は、インバウンド・アダプタファイル、設定上のあたりのよう

<?xml version="1.0" encoding="UTF-8"?> 
<beans xmlns="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:int="http://www.springframework.org/schema/integration" 
    xmlns:file="http://www.springframework.org/schema/integration/file" 
    xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" 
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
      http://www.springframework.org/schema/beans/spring-beans.xsd 
      http://www.springframework.org/schema/integration 
      http://www.springframework.org/schema/integration/spring-integration.xsd 
      http://www.springframework.org/schema/integration/file 
      http://www.springframework.org/schema/integration/file/spring-integration-file.xsd 
      http://www.springframework.org/schema/context 
      http://www.springframework.org/schema/context/spring-context.xsd"> 

    <int:channel id="controlChannel" /> 

    <int:channel id="adapterInputChanel"> 
     <int:queue /> 
    </int:channel> 

    <int:control-bus input-channel="controlChannel" /> 

    <file:inbound-channel-adapter id="inboundAdapter" 
     directory="inputdir" 
     channel="adapterInputChanel" auto-startup="false" prevent-duplicates="true" 
     ignore-hidden="true"> 
     <int:poller id="poller" fixed-delay="5000" 
      max-messages-per-poll="1"> 
     </int:poller> 
    </file:inbound-channel-adapter> 


    <int:service-activator input-channel="adapterInputChanel" 
     ref="mainService" method="readFiles" output-channel="filesOut"> 
     <int:poller fixed-delay="500" /> 
    </int:service-activator> 

    <bean id="mainService" class="com.sample.MainService"> 

    </bean> 

    <file:outbound-channel-adapter id="filesOut" 
     directory="output dir" /> 

</beans> 

、アプリケーションコンテキストのコンフィギュレーションの下に持って

は、ポーリングごとに一つのファイルを取得し、サービス実行を実行します。

しかし、システムが別のファイルを取得している場合、最初のトランザクションが終了するまでファイルインバウンドアダプタはサービスを再開しません。

いくつかのサンプルでこの問題を処理する方法を教えてください。

Answer 1

<queue/>をadapterInputChanelから削除し、サービスアクティベータから<poller/>を削除します。

次に、チャネルはDirectChannelになり、サービスはアダプタのポーラースレッド上で実行され、サービスが終了するまで次のファイルは処理されません。

約different channel types hereを読むことができます。具体的には購読可能なチャネルとポーリング可能なチャネルの違いです