Package org.springframework.batch.integration.chunk

@NullMarked package org.springframework.batch.integration.chunk

Components for remote chunking.

Author:

Michael Minella, Mahmoud Ben Hassine, Stefano Cordio

Related Packages

Package	Description
org.springframework.batch.integration	Provides integration with Spring Integration.

Class	Description
AsynchronousFailureException	Exception indicating that a failure or early completion condition was detected in a remote worker.
ChunkMessageChannelItemWriter<T>
ChunkMessageChannelItemWriter.LocalState
ChunkProcessorChunkRequestHandler<S>	A ChunkRequestHandler based on a ChunkProcessor.
ChunkRequest<T>	Encapsulation of a chunk of items to be processed remotely as part of a step execution.
ChunkRequestHandler<T>	Interface for a remote worker in the Remote Chunking pattern.
ChunkResponse	Encapsulates a response to processing a chunk of items, summarising the result as a StepContribution.
ChunkTaskExecutorItemWriter<T>	Similar to ChunkMessageChannelItemWriter, this item writer submits chunk requests to local workers from a TaskExecutor instead of sending them over a message channel to remote workers.
JmsRedeliveredExtractor
MessageSourcePollerInterceptor	A ChannelInterceptor that turns a pollable channel into a "pass-thru channel": if a client calls receive() on the channel it will delegate to a MessageSource to pull the message directly from an external source.
RemoteChunkHandlerFactoryBean<T>	Deprecated, for removal: This API element is subject to removal in a future version. since 6.0 with no replacement, as it is only used by the deprecated batch-integration XML namespace.
RemoteChunkingManagerStepBuilder<I,O>	Builder for a manager step in a remote chunking setup.
RemoteChunkingManagerStepBuilderFactory	Convenient factory for a RemoteChunkingManagerStepBuilder which sets the JobRepository and PlatformTransactionManager automatically.
RemoteChunkingWorkerBuilder<I,O>	Builder for a worker in a remote chunking setup.
StepContributionSource	A source of StepContribution instances that can be aggregated and used to update an ongoing StepExecution.