パッケージ org.springframework.batch.integration.chunk

クラス RemoteChunkingWorkerBuilder<I,O>

java.lang.ObjectSE
org.springframework.batch.integration.chunk.RemoteChunkingWorkerBuilder<I,O>
型パラメーター:
I - 入力項目の型
O - 出力項目の型
public class RemoteChunkingWorkerBuilder<I,O> extends ObjectSE
リモートチャンク設定のワーカーのビルダー。このビルダー:
  • 提供されたアイテムプロセッサーとライターを使用して ChunkProcessorChunkHandler を作成します。アイテムプロセッサーが提供されていない場合は、PassThroughItemProcessor が使用されます
  • inputChannel で受信リクエストをリッスンし、outputChannel で応答を送信するサービスアクティベーターとして ChunkProcessorChunkHandler を使用して IntegrationFlow を作成します
導入:
4.1
作成者:
Mahmoud Ben Hassine

  • コンストラクターの詳細

    • RemoteChunkingWorkerBuilder

      public RemoteChunkingWorkerBuilder()

  • メソッドの詳細

    • itemProcessor

      public RemoteChunkingWorkerBuilder<I,O> itemProcessor(ItemProcessor<I,O> itemProcessor)
      manager ステップによって送信された項目を処理するために使用する ItemProcessor を設定します。
      パラメーター:
      itemProcessor - 使用対象
      戻り値:
      流れるような連鎖のためのこのビルダーインスタンス

    • itemWriter

      public RemoteChunkingWorkerBuilder<I,O> itemWriter(ItemWriter<O> itemWriter)
      manager ステップによって送信された項目を書き込むために使用する ItemWriter を設定します。
      パラメーター:
      itemWriter - 使用対象
      戻り値:
      流れるような連鎖のためのこのビルダーインスタンス

    • inputChannel

      public RemoteChunkingWorkerBuilder<I,O> inputChannel(org.springframework.messaging.MessageChannel inputChannel)
      管理者が送信したアイテムを受信する入力チャネルを設定します。
      パラメーター:
      inputChannel - 入力チャンネル
      戻り値:
      流れるような連鎖のためのこのビルダーインスタンス

    • outputChannel

      public RemoteChunkingWorkerBuilder<I,O> outputChannel(org.springframework.messaging.MessageChannel outputChannel)
      応答がマネージャーステップに送信される出力チャネルを設定します。
      パラメーター:
      outputChannel - 出力チャネル
      戻り値:
      流れるような連鎖のためのこのビルダーインスタンス

    • build

      public org.springframework.integration.dsl.IntegrationFlow build()
      入力チャネルをリッスンし、出力チャネルで応答するサービスアクティベーターとして構成された ChunkProcessorChunkHandler を使用して、IntegrationFlow を作成します。
      戻り値:
      統合フロー