类 ChunkMessageChannelItemWriter<T>

构造器详细资料

• ChunkMessageChannelItemWriter

  public ChunkMessageChannelItemWriter()

方法详细资料

• setMaxWaitTimeouts

  public 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. This is a multiplier on the receive timeout set separately on the gateway. The ideal value is a compromise between allowing slow workers time to finish, and responsiveness if there is a dead worker. Defaults to 40.

  参数:

  maxWaitTimeouts - the maximum number of wait timeouts

• setThrottleLimit

  public void setThrottleLimit​(long throttleLimit)

  Public setter for the throttle limit. This limits the number of pending requests for chunk processing to avoid overwhelming the receivers.

  参数:

  throttleLimit - the throttle limit to set

• setMessagingOperations

  public void setMessagingOperations​(org.springframework.integration.core.MessagingTemplate messagingGateway)

• setReplyChannel

  public void setReplyChannel​(org.springframework.messaging.PollableChannel replyChannel)

• write

  public void write​(java.util.List<? extends T> items)
             throws java.lang.Exception

  从接口复制的说明: ItemWriter
  Process the supplied data element. Will not be called with any null items in normal operation.

  指定者:

  write 在接口中 ItemWriter<T>

  参数:

  items - items to be written

  抛出:

  java.lang.Exception - if there are errors. The framework will catch the exception and convert or rethrow it as appropriate.

• beforeStep

  public void beforeStep​(StepExecution stepExecution)

  从接口复制的说明: StepExecutionListener
  Initialize the state of the listener with the StepExecution from the current scope.

  指定者:

  beforeStep 在接口中 StepExecutionListener

  覆盖:

  beforeStep 在类中 StepExecutionListenerSupport

  参数:

  stepExecution - instance of StepExecution.

• afterStep

  public ExitStatus afterStep​(StepExecution stepExecution)

  从接口复制的说明: StepExecutionListener
  Give a listener a chance to modify the exit status from a step. The value returned will be combined with the normal exit status using ExitStatus.and(ExitStatus). Called after execution of step's processing logic (both successful or failed). Throwing exception in this method has no effect, it will only be logged.

  指定者:

  afterStep 在接口中 StepExecutionListener

  覆盖:

  afterStep 在类中 StepExecutionListenerSupport

  参数:

  stepExecution - StepExecution instance.

  返回:

  an ExitStatus to combine with the normal value. Return null to leave the old value unchanged.

• close

  public void close()
             throws ItemStreamException

  从接口复制的说明: ItemStream
  If any resources are needed for the stream to operate they need to be destroyed here. Once this method has been called all other methods (except open) may throw an exception.

  指定者:

  close 在接口中 ItemStream

  抛出:

  ItemStreamException

• open

  public void open​(ExecutionContext executionContext)
            throws ItemStreamException

  从接口复制的说明: ItemStream
  Open the stream for the provided ExecutionContext.

  指定者:

  open 在接口中 ItemStream

  参数:

  executionContext - current step's ExecutionContext. Will be the executionContext from the last run of the step on a restart.

  抛出:

  ItemStreamException

• update

  public void update​(ExecutionContext executionContext)
              throws ItemStreamException

  从接口复制的说明: ItemStream
  Indicates that the execution context provided during open is about to be saved. If any state is remaining, but has not been put in the context, it should be added here.

  指定者:

  update 在接口中 ItemStream

  参数:

  executionContext - to be updated

  抛出:

  ItemStreamException

• getStepContributions

  public java.util.Collection<StepContribution> getStepContributions()

  从接口复制的说明: StepContributionSource
  Get the currently available contributions and drain the source. The next call would return an empty collection, unless new contributions have arrived.

  指定者:

  getStepContributions 在接口中 StepContributionSource

  返回:

  a collection of StepContribution instances