Uses of Class
org.springframework.batch.integration.chunk.RemoteChunkingManagerStepBuilder
Packages that use RemoteChunkingManagerStepBuilder
-
Uses of RemoteChunkingManagerStepBuilder in org.springframework.batch.integration.chunk
Methods in org.springframework.batch.integration.chunk that return RemoteChunkingManagerStepBuilderModifier 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 aRemoteChunkingManagerStepBuilderand 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 theMessagingTemplateto 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) Deprecated, for removal: This API element is subject to removal in a future version.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 aUnsupportedOperationExceptionsince the item writer of the manager step in a remote chunking setup will be automatically set to an instance ofChunkMessageChannelItemWriter.
RemoteChunkingManagerStepBuilder(String, JobRepository)