I
- 入力項目の型 O
- 出力項目の型 public class RemoteChunkingWorkerBuilder<I,O>
extends java.lang.Object
ChunkProcessorChunkHandler
を作成します。アイテムプロセッサーが提供されていない場合は、PassThroughItemProcessor
が使用されます inputChannel
で受信リクエストをリッスンし、outputChannel
で応答を送信するサービスアクティベーターとして ChunkProcessorChunkHandler
を使用して IntegrationFlow
を作成します コンストラクターと説明 |
---|
RemoteChunkingWorkerBuilder() |
修飾子と型 | メソッドと説明 |
---|---|
org.springframework.integration.dsl.IntegrationFlow | build() 入力チャネルをリッスンし、出力チャネルで応答するサービスアクティベーターとして構成された ChunkProcessorChunkHandler を使用して、IntegrationFlow を作成します。 |
RemoteChunkingWorkerBuilder<I, O> | inputChannel(org.springframework.messaging.MessageChannel inputChannel) マスターが送信したアイテムを受信する入力チャネルを設定します。 |
RemoteChunkingWorkerBuilder<I, O> | itemProcessor(ItemProcessor<I, O> itemProcessor) マスターステップから送信されたアイテムの処理に使用する ItemProcessor を設定します。 |
RemoteChunkingWorkerBuilder<I, O> | itemWriter(ItemWriter<O> itemWriter) マスターステップによって送信されたアイテムの書き込みに使用する ItemWriter を設定します。 |
RemoteChunkingWorkerBuilder<I, O> | outputChannel(org.springframework.messaging.MessageChannel outputChannel) 応答がマスターステップに送信される出力チャネルを設定します。 |
public RemoteChunkingWorkerBuilder<I,O> itemProcessor(ItemProcessor<I,O> itemProcessor)
ItemProcessor
を設定します。itemProcessor
- 使用対象 public RemoteChunkingWorkerBuilder<I,O> itemWriter(ItemWriter<O> itemWriter)
ItemWriter
を設定します。itemWriter
- 使用対象 public RemoteChunkingWorkerBuilder<I,O> inputChannel(org.springframework.messaging.MessageChannel inputChannel)
inputChannel
- 入力チャンネル public RemoteChunkingWorkerBuilder<I,O> outputChannel(org.springframework.messaging.MessageChannel outputChannel)
outputChannel
- 出力チャネル public org.springframework.integration.dsl.IntegrationFlow build()
ChunkProcessorChunkHandler
を使用して、IntegrationFlow
を作成します。