类 RemoteChunkingWorkerBuilder<I,O>
- java.lang.Object
- org.springframework.batch.integration.chunk.RemoteChunkingWorkerBuilder<I,O>
- 类型参数:
I- type of input itemsO- type of output items
public class RemoteChunkingWorkerBuilder<I,O> extends java.lang.Object
Builder for a worker in a remote chunking setup. This builder:- creates a
ChunkProcessorChunkHandlerwith the provided item processor and writer. If no item processor is provided, aPassThroughItemProcessorwill be used - creates an
IntegrationFlowwith theChunkProcessorChunkHandleras a service activator which listens to incoming requests oninputChanneland sends replies onoutputChannel
- 从以下版本开始:
- 4.1
- 作者:
- Mahmoud Ben Hassine
构造器概要
构造器 构造器 说明 RemoteChunkingWorkerBuilder()
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 org.springframework.integration.dsl.IntegrationFlowbuild()Create anIntegrationFlowwith aChunkProcessorChunkHandlerconfigured as a service activator listening to the input channel and replying on the output channel.RemoteChunkingWorkerBuilder<I,O>inputChannel(org.springframework.messaging.MessageChannel inputChannel)Set the input channel on which items sent by the master are received.RemoteChunkingWorkerBuilder<I,O>itemProcessor(ItemProcessor<I,O> itemProcessor)Set theItemProcessorto use to process items sent by the master step.RemoteChunkingWorkerBuilder<I,O>itemWriter(ItemWriter<O> itemWriter)Set theItemWriterto use to write items sent by the master step.RemoteChunkingWorkerBuilder<I,O>outputChannel(org.springframework.messaging.MessageChannel outputChannel)Set the output channel on which replies will be sent to the master step.
构造器详细资料
RemoteChunkingWorkerBuilder
public RemoteChunkingWorkerBuilder()
方法详细资料
itemProcessor
public RemoteChunkingWorkerBuilder<I,O> itemProcessor(ItemProcessor<I,O> itemProcessor)
Set theItemProcessorto use to process items sent by the master step.- 参数:
itemProcessor- to use- 返回:
- this builder instance for fluent chaining
itemWriter
public RemoteChunkingWorkerBuilder<I,O> itemWriter(ItemWriter<O> itemWriter)
Set theItemWriterto use to write items sent by the master step.- 参数:
itemWriter- to use- 返回:
- this builder instance for fluent chaining
inputChannel
public RemoteChunkingWorkerBuilder<I,O> inputChannel(org.springframework.messaging.MessageChannel inputChannel)
Set the input channel on which items sent by the master are received.- 参数:
inputChannel- the input channel- 返回:
- this builder instance for fluent chaining
outputChannel
public RemoteChunkingWorkerBuilder<I,O> outputChannel(org.springframework.messaging.MessageChannel outputChannel)
Set the output channel on which replies will be sent to the master step.- 参数:
outputChannel- the output channel- 返回:
- this builder instance for fluent chaining
build
public org.springframework.integration.dsl.IntegrationFlow build()
Create anIntegrationFlowwith aChunkProcessorChunkHandlerconfigured as a service activator listening to the input channel and replying on the output channel.- 返回:
- the integration flow