Uses of Class
org.springframework.batch.integration.chunk.RemoteChunkingManagerStepBuilder
-
Uses of RemoteChunkingManagerStepBuilder in org.springframework.batch.integration.chunk
Modifier and TypeMethodDescriptionRemoteChunkingManagerStepBuilder.allowStartIfComplete
(boolean allowStartIfComplete) RemoteChunkingManagerStepBuilder.backOffPolicy
(org.springframework.retry.backoff.BackOffPolicy backOffPolicy) RemoteChunkingManagerStepBuilder.chunk
(int chunkSize) RemoteChunkingManagerStepBuilder.chunk
(CompletionPolicy completionPolicy) RemoteChunkingManagerStepBuilder.chunkOperations
(RepeatOperations repeatTemplate) RemoteChunkingManagerStepBuilder.exceptionHandler
(ExceptionHandler exceptionHandler) <I,
O> RemoteChunkingManagerStepBuilder<I, O> Creates aRemoteChunkingManagerStepBuilder
and initializes its job repository and transaction manager.RemoteChunkingManagerStepBuilder.inputChannel
(org.springframework.messaging.PollableChannel inputChannel) Set the input channel on which replies from workers will be received.RemoteChunkingManagerStepBuilder.keyGenerator
(KeyGenerator keyGenerator) RemoteChunkingManagerStepBuilder.listener
(ChunkListener listener) RemoteChunkingManagerStepBuilder.listener
(ItemReadListener<? super I> listener) RemoteChunkingManagerStepBuilder.listener
(ItemWriteListener<? super O> listener) RemoteChunkingManagerStepBuilder.listener
(SkipListener<? super I, ? super O> listener) RemoteChunkingManagerStepBuilder.listener
(StepExecutionListener listener) RemoteChunkingManagerStepBuilder.listener
(org.springframework.retry.RetryListener listener) RemoteChunkingManagerStepBuilder.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.RemoteChunkingManagerStepBuilder.messagingTemplate
(org.springframework.integration.core.MessagingTemplate messagingTemplate) Set theMessagingTemplate
to use to send data to workers.RemoteChunkingManagerStepBuilder.noRollback
(Class<? extends Throwable> type) RemoteChunkingManagerStepBuilder.outputChannel
(org.springframework.messaging.MessageChannel outputChannel) Set the output channel on which requests to workers will be sent.RemoteChunkingManagerStepBuilder.processor
(ItemProcessor<? super I, ? extends O> itemProcessor) RemoteChunkingManagerStepBuilder.reader
(ItemReader<? extends I> reader) RemoteChunkingManagerStepBuilder.readerIsTransactionalQueue()
RemoteChunkingManagerStepBuilder.repository
(JobRepository jobRepository) RemoteChunkingManagerStepBuilder.retryContextCache
(org.springframework.retry.policy.RetryContextCache retryContextCache) RemoteChunkingManagerStepBuilder.retryLimit
(int retryLimit) RemoteChunkingManagerStepBuilder.retryPolicy
(org.springframework.retry.RetryPolicy retryPolicy) RemoteChunkingManagerStepBuilder.skipLimit
(int skipLimit) RemoteChunkingManagerStepBuilder.skipPolicy
(SkipPolicy skipPolicy) RemoteChunkingManagerStepBuilder.startLimit
(int startLimit) RemoteChunkingManagerStepBuilder.stepOperations
(RepeatOperations repeatTemplate) RemoteChunkingManagerStepBuilder.stream
(ItemStream stream) RemoteChunkingManagerStepBuilder.throttleLimit
(long throttleLimit) Public setter for the throttle limit.RemoteChunkingManagerStepBuilder.transactionAttribute
(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute) RemoteChunkingManagerStepBuilder.transactionManager
(org.springframework.transaction.PlatformTransactionManager transactionManager) RemoteChunkingManagerStepBuilder.writer
(ItemWriter<? super O> writer) This method will throw aUnsupportedOperationException
since the item writer of the manager step in a remote chunking setup will be automatically set to an instance ofChunkMessageChannelItemWriter
.