I - type of input itemsO - type of output itemspublic class RemoteChunkingMasterStepBuilder<I,O>
extends org.springframework.batch.core.step.builder.FaultTolerantStepBuilder<I,O>
ChunkMessageChannelItemWriter on the master step.
If no messagingTemplate is provided through
messagingTemplate(MessagingTemplate),
this builder will create one and set its default channel to the outputChannel
provided through outputChannel(MessageChannel).
If a messagingTemplate is provided, it is assumed that it is fully configured
and that its default channel is set to an output channel on which requests to workers
will be sent.
| Constructor and Description |
|---|
RemoteChunkingMasterStepBuilder(java.lang.String stepName)
Create a new
RemoteChunkingMasterStepBuilder. |
| Modifier and Type | Method and Description |
|---|---|
RemoteChunkingMasterStepBuilder<I,O> |
allowStartIfComplete(boolean allowStartIfComplete) |
RemoteChunkingMasterStepBuilder<I,O> |
backOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy) |
org.springframework.batch.core.step.tasklet.TaskletStep |
build()
Build a master
TaskletStep. |
RemoteChunkingMasterStepBuilder<I,O> |
chunk(org.springframework.batch.repeat.CompletionPolicy completionPolicy) |
RemoteChunkingMasterStepBuilder<I,O> |
chunk(int chunkSize) |
RemoteChunkingMasterStepBuilder<I,O> |
chunkOperations(org.springframework.batch.repeat.RepeatOperations repeatTemplate) |
RemoteChunkingMasterStepBuilder<I,O> |
exceptionHandler(org.springframework.batch.repeat.exception.ExceptionHandler exceptionHandler) |
RemoteChunkingMasterStepBuilder<I,O> |
inputChannel(org.springframework.messaging.PollableChannel inputChannel)
Set the input channel on which replies from workers will be received.
|
RemoteChunkingMasterStepBuilder<I,O> |
keyGenerator(org.springframework.batch.core.step.item.KeyGenerator keyGenerator) |
RemoteChunkingMasterStepBuilder<I,O> |
listener(org.springframework.batch.core.ChunkListener listener) |
RemoteChunkingMasterStepBuilder<I,O> |
listener(org.springframework.batch.core.ItemReadListener<? super I> listener) |
RemoteChunkingMasterStepBuilder<I,O> |
listener(org.springframework.batch.core.ItemWriteListener<? super O> listener) |
RemoteChunkingMasterStepBuilder<I,O> |
listener(java.lang.Object listener) |
RemoteChunkingMasterStepBuilder<I,O> |
listener(org.springframework.retry.RetryListener listener) |
RemoteChunkingMasterStepBuilder<I,O> |
listener(org.springframework.batch.core.SkipListener<? super I,? super O> listener) |
RemoteChunkingMasterStepBuilder<I,O> |
listener(org.springframework.batch.core.StepExecutionListener listener) |
RemoteChunkingMasterStepBuilder<I,O> |
maxWaitTimeouts(int maxWaitTimeouts)
The maximum number of times to wait at the end of a step for a non-null result from the remote workers.
|
RemoteChunkingMasterStepBuilder<I,O> |
messagingTemplate(org.springframework.integration.core.MessagingTemplate messagingTemplate)
Set the
MessagingTemplate to use to send data to workers. |
RemoteChunkingMasterStepBuilder<I,O> |
noRetry(java.lang.Class<? extends java.lang.Throwable> type) |
RemoteChunkingMasterStepBuilder<I,O> |
noRollback(java.lang.Class<? extends java.lang.Throwable> type) |
RemoteChunkingMasterStepBuilder<I,O> |
noSkip(java.lang.Class<? extends java.lang.Throwable> type) |
RemoteChunkingMasterStepBuilder<I,O> |
outputChannel(org.springframework.messaging.MessageChannel outputChannel)
Set the output channel on which requests to workers will be sent.
|
RemoteChunkingMasterStepBuilder<I,O> |
processor(org.springframework.batch.item.ItemProcessor<? super I,? extends O> itemProcessor) |
RemoteChunkingMasterStepBuilder<I,O> |
reader(org.springframework.batch.item.ItemReader<? extends I> reader) |
RemoteChunkingMasterStepBuilder<I,O> |
readerIsTransactionalQueue() |
RemoteChunkingMasterStepBuilder<I,O> |
repository(org.springframework.batch.core.repository.JobRepository jobRepository) |
RemoteChunkingMasterStepBuilder<I,O> |
retry(java.lang.Class<? extends java.lang.Throwable> type) |
RemoteChunkingMasterStepBuilder<I,O> |
retryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache) |
RemoteChunkingMasterStepBuilder<I,O> |
retryLimit(int retryLimit) |
RemoteChunkingMasterStepBuilder<I,O> |
retryPolicy(org.springframework.retry.RetryPolicy retryPolicy) |
RemoteChunkingMasterStepBuilder<I,O> |
skip(java.lang.Class<? extends java.lang.Throwable> type) |
RemoteChunkingMasterStepBuilder<I,O> |
skipLimit(int skipLimit) |
RemoteChunkingMasterStepBuilder<I,O> |
skipPolicy(org.springframework.batch.core.step.skip.SkipPolicy skipPolicy) |
RemoteChunkingMasterStepBuilder<I,O> |
startLimit(int startLimit) |
RemoteChunkingMasterStepBuilder<I,O> |
stepOperations(org.springframework.batch.repeat.RepeatOperations repeatTemplate) |
RemoteChunkingMasterStepBuilder<I,O> |
stream(org.springframework.batch.item.ItemStream stream) |
RemoteChunkingMasterStepBuilder<I,O> |
throttleLimit(long throttleLimit)
Public setter for the throttle limit.
|
RemoteChunkingMasterStepBuilder<I,O> |
transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute) |
RemoteChunkingMasterStepBuilder<I,O> |
transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
RemoteChunkingMasterStepBuilder<I,O> |
writer(org.springframework.batch.item.ItemWriter<? super O> writer)
This method will throw a
UnsupportedOperationException since
the item writer of the master step in a remote chunking setup will be
automatically set to an instance of ChunkMessageChannelItemWriter. |
createChunkProcessor, createChunkProvider, createRetryOperations, createSkipPolicy, createTasklet, detectStreamInReader, getChunkMonitor, getFatalExceptionAwareProxy, getJsrRetryListeners, getRollbackClassifier, getSkipListeners, listener, processorNonTransactional, registerStepListenerAsSkipListenercreateChunkOperations, faultTolerant, getChunkCompletionPolicy, getChunkSize, getItemListeners, getProcessor, getReader, getWriter, isReaderTransactionalQueue, listener, processor, registerAsStreamsAndListeners, registerStepListenerAsItemListenerconcurrent, getExceptionHandler, getStepOperations, getStreams, getTaskExecutor, getThrottleLimit, getTransactionAttribute, registerStepListenerAsChunkListener, taskExecutor, throttleLimitpublic RemoteChunkingMasterStepBuilder(java.lang.String stepName)
RemoteChunkingMasterStepBuilder.stepName - name of the master steppublic RemoteChunkingMasterStepBuilder<I,O> inputChannel(org.springframework.messaging.PollableChannel inputChannel)
ChunkMessageChannelItemWriter created by this builder.inputChannel - the input channelChunkMessageChannelItemWriter.setReplyChannel(org.springframework.messaging.PollableChannel)public RemoteChunkingMasterStepBuilder<I,O> outputChannel(org.springframework.messaging.MessageChannel outputChannel)
Use either this setter or messagingTemplate(MessagingTemplate)
to provide a fully configured messaging template.
outputChannel - the output channel.messagingTemplate(MessagingTemplate)public RemoteChunkingMasterStepBuilder<I,O> messagingTemplate(org.springframework.integration.core.MessagingTemplate messagingTemplate)
MessagingTemplate to use to send data to workers.
The default channel of the messaging template must be set.
Use either this setter to provide a fully configured messaging template or
provide an output channel through outputChannel(MessageChannel)
and a default messaging template will be created.
messagingTemplate - the messaging template to useoutputChannel(MessageChannel)public RemoteChunkingMasterStepBuilder<I,O> maxWaitTimeouts(int maxWaitTimeouts)
maxWaitTimeouts - the maximum number of wait timeoutsChunkMessageChannelItemWriter.setMaxWaitTimeouts(int)public RemoteChunkingMasterStepBuilder<I,O> throttleLimit(long throttleLimit)
throttleLimit - the throttle limit to setChunkMessageChannelItemWriter.setThrottleLimit(long)public org.springframework.batch.core.step.tasklet.TaskletStep build()
TaskletStep.build in class org.springframework.batch.core.step.builder.FaultTolerantStepBuilder<I,O>RemoteChunkHandlerFactoryBeanpublic RemoteChunkingMasterStepBuilder<I,O> reader(org.springframework.batch.item.ItemReader<? extends I> reader)
public RemoteChunkingMasterStepBuilder<I,O> repository(org.springframework.batch.core.repository.JobRepository jobRepository)
public RemoteChunkingMasterStepBuilder<I,O> transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
public RemoteChunkingMasterStepBuilder<I,O> listener(java.lang.Object listener)
public RemoteChunkingMasterStepBuilder<I,O> listener(org.springframework.batch.core.SkipListener<? super I,? super O> listener)
public RemoteChunkingMasterStepBuilder<I,O> listener(org.springframework.batch.core.ChunkListener listener)
public RemoteChunkingMasterStepBuilder<I,O> transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)
public RemoteChunkingMasterStepBuilder<I,O> listener(org.springframework.retry.RetryListener listener)
public RemoteChunkingMasterStepBuilder<I,O> keyGenerator(org.springframework.batch.core.step.item.KeyGenerator keyGenerator)
public RemoteChunkingMasterStepBuilder<I,O> retryLimit(int retryLimit)
public RemoteChunkingMasterStepBuilder<I,O> retryPolicy(org.springframework.retry.RetryPolicy retryPolicy)
public RemoteChunkingMasterStepBuilder<I,O> backOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy)
public RemoteChunkingMasterStepBuilder<I,O> retryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache)
public RemoteChunkingMasterStepBuilder<I,O> skipLimit(int skipLimit)
public RemoteChunkingMasterStepBuilder<I,O> noSkip(java.lang.Class<? extends java.lang.Throwable> type)
public RemoteChunkingMasterStepBuilder<I,O> skip(java.lang.Class<? extends java.lang.Throwable> type)
public RemoteChunkingMasterStepBuilder<I,O> skipPolicy(org.springframework.batch.core.step.skip.SkipPolicy skipPolicy)
public RemoteChunkingMasterStepBuilder<I,O> noRollback(java.lang.Class<? extends java.lang.Throwable> type)
public RemoteChunkingMasterStepBuilder<I,O> noRetry(java.lang.Class<? extends java.lang.Throwable> type)
public RemoteChunkingMasterStepBuilder<I,O> retry(java.lang.Class<? extends java.lang.Throwable> type)
public RemoteChunkingMasterStepBuilder<I,O> stream(org.springframework.batch.item.ItemStream stream)
public RemoteChunkingMasterStepBuilder<I,O> chunk(int chunkSize)
public RemoteChunkingMasterStepBuilder<I,O> chunk(org.springframework.batch.repeat.CompletionPolicy completionPolicy)
public RemoteChunkingMasterStepBuilder<I,O> writer(org.springframework.batch.item.ItemWriter<? super O> writer) throws java.lang.UnsupportedOperationException
UnsupportedOperationException since
the item writer of the master step in a remote chunking setup will be
automatically set to an instance of ChunkMessageChannelItemWriter.
When building a master step for remote chunking, no item writer must be
provided.writer in class org.springframework.batch.core.step.builder.SimpleStepBuilder<I,O>java.lang.UnsupportedOperationException - if an item writer is providedChunkMessageChannelItemWriter,
RemoteChunkHandlerFactoryBean.setChunkWriter(ItemWriter)public RemoteChunkingMasterStepBuilder<I,O> readerIsTransactionalQueue()
public RemoteChunkingMasterStepBuilder<I,O> listener(org.springframework.batch.core.ItemReadListener<? super I> listener)
public RemoteChunkingMasterStepBuilder<I,O> listener(org.springframework.batch.core.ItemWriteListener<? super O> listener)
public RemoteChunkingMasterStepBuilder<I,O> chunkOperations(org.springframework.batch.repeat.RepeatOperations repeatTemplate)
public RemoteChunkingMasterStepBuilder<I,O> exceptionHandler(org.springframework.batch.repeat.exception.ExceptionHandler exceptionHandler)
public RemoteChunkingMasterStepBuilder<I,O> stepOperations(org.springframework.batch.repeat.RepeatOperations repeatTemplate)
public RemoteChunkingMasterStepBuilder<I,O> startLimit(int startLimit)
public RemoteChunkingMasterStepBuilder<I,O> listener(org.springframework.batch.core.StepExecutionListener listener)
public RemoteChunkingMasterStepBuilder<I,O> allowStartIfComplete(boolean allowStartIfComplete)