public class ChunkMessageChannelItemWriter<T> extends org.springframework.batch.core.listener.StepExecutionListenerSupport implements org.springframework.batch.item.ItemWriter<T>, org.springframework.batch.item.ItemStream, StepContributionSource
| Constructor and Description |
|---|
ChunkMessageChannelItemWriter() |
| Modifier and Type | Method and Description |
|---|---|
org.springframework.batch.core.ExitStatus |
afterStep(org.springframework.batch.core.StepExecution stepExecution) |
void |
beforeStep(org.springframework.batch.core.StepExecution stepExecution) |
void |
close() |
java.util.Collection<org.springframework.batch.core.StepContribution> |
getStepContributions()
Get the currently available contributions and drain the source.
|
void |
open(org.springframework.batch.item.ExecutionContext executionContext) |
void |
setMaxWaitTimeouts(int maxWaitTimeouts)
The maximum number of times to wait at the end of a step for a non-null result from the remote workers.
|
void |
setMessagingOperations(org.springframework.integration.core.MessagingTemplate messagingGateway) |
void |
setReplyChannel(org.springframework.messaging.PollableChannel replyChannel) |
void |
setThrottleLimit(long throttleLimit)
Public setter for the throttle limit.
|
void |
update(org.springframework.batch.item.ExecutionContext executionContext) |
void |
write(java.util.List<? extends T> items) |
public void setMaxWaitTimeouts(int maxWaitTimeouts)
maxWaitTimeouts - the maximum number of wait timeoutspublic void setThrottleLimit(long throttleLimit)
throttleLimit - the throttle limit to setpublic void setMessagingOperations(org.springframework.integration.core.MessagingTemplate messagingGateway)
public void setReplyChannel(org.springframework.messaging.PollableChannel replyChannel)
public void write(java.util.List<? extends T> items) throws java.lang.Exception
write in interface org.springframework.batch.item.ItemWriter<T>java.lang.Exceptionpublic void beforeStep(org.springframework.batch.core.StepExecution stepExecution)
beforeStep in interface org.springframework.batch.core.StepExecutionListenerbeforeStep in class org.springframework.batch.core.listener.StepExecutionListenerSupportpublic org.springframework.batch.core.ExitStatus afterStep(org.springframework.batch.core.StepExecution stepExecution)
afterStep in interface org.springframework.batch.core.StepExecutionListenerafterStep in class org.springframework.batch.core.listener.StepExecutionListenerSupportpublic void close()
throws org.springframework.batch.item.ItemStreamException
close in interface org.springframework.batch.item.ItemStreamorg.springframework.batch.item.ItemStreamExceptionpublic void open(org.springframework.batch.item.ExecutionContext executionContext)
throws org.springframework.batch.item.ItemStreamException
open in interface org.springframework.batch.item.ItemStreamorg.springframework.batch.item.ItemStreamExceptionpublic void update(org.springframework.batch.item.ExecutionContext executionContext)
throws org.springframework.batch.item.ItemStreamException
update in interface org.springframework.batch.item.ItemStreamorg.springframework.batch.item.ItemStreamExceptionpublic java.util.Collection<org.springframework.batch.core.StepContribution> getStepContributions()
StepContributionSourcegetStepContributions in interface StepContributionSourceStepContribution instances