ファイルを取得できませんサービスアクティベータが処理します - ファイル受信チャネルアダプタ

Question

ディレクトリをポーリングするファイル受信チャネルアダプタを実装しました。他のインバウンドプロセスから複数のファイルを受け取ることができます。その中から、マージするいくつかの一意のファイルを選択する必要があります。このジョブを実行するためのカスタムフィルタを実装しました（一意のファイルを取得してサービスアクティベータに渡すため）。

サービスアクティベータでは、ファイルを1つずつ受信します。実際にフィルタクラスからの現在のポーリングでマージするファイルがいくつあっても、1つのファイルまたは複数のファイルしか存在しない可能性があります。

私の質問は、サービスアクティベータクラスで受信するファイルの数を確認する方法です。 Filterクラスから受け取ったファイルの数に基づいてビジネスを実行できるようにするには？

Serviceアクティベータクラスに、フィルタクラスからそのポーリングで受信するファイルの数を知る方法はありますか？

Answer 1

<poller>のようなオプションがありますが、いくつかの合理的な値を持つ、だから、

<xsd:attribute name="max-messages-per-poll" type="xsd:string"> 
     <xsd:annotation> 
      <xsd:documentation> 
       The maximum number of messages that will be produced for each poll. Defaults to 
       infinity (indicated by -1) for polling consumers, and 1 for polled 
       inbound channel adapters. 
      </xsd:documentation> 
     </xsd:annotation> 
    </xsd:attribute> 

を、あなたは一番上にあなたのサービスを制限します。 各メッセージを別々のスレッドに移動しない場合は、サービスにAtomicIntegerを数えて送信するだけです。そして、ポーリングタスクの最後に、次のポーリングで再度計算する準備ができるように、そのカウンタをリセットすることができます。この目的のためにresult == nullの場合にはAbstractMessageSourceAdviceをafterReceive()リセットカウンターのように実装することができます。

はリファレンスマニュアルで詳細情報を参照してください：http://docs.spring.io/spring-integration/reference/html/messaging-channels-section.html#conditional-pollers