类 JsrFaultTolerantChunkProcessor<I,​O>

字段详细资料

• logger

  protected final org.apache.commons.logging.Log logger

构造器详细资料

• JsrFaultTolerantChunkProcessor

  public JsrFaultTolerantChunkProcessor​(ItemReader<? extends I> reader,
                                        ItemProcessor<? super I,​? extends O> processor,
                                        ItemWriter<? super O> writer,
                                        RepeatOperations repeatTemplate,
                                        BatchRetryTemplate batchRetryTemplate)

方法详细资料

• setSkipPolicy

  public void setSkipPolicy​(SkipPolicy skipPolicy)

  参数:

  skipPolicy - a SkipPolicy

• setRollbackClassifier

  public void setRollbackClassifier​(org.springframework.classify.Classifier<java.lang.Throwable,​java.lang.Boolean> rollbackClassifier)

  参数:

  rollbackClassifier - a Classifier

• setChunkMonitor

  public void setChunkMonitor​(ChunkMonitor chunkMonitor)

  参数:

  chunkMonitor - a ChunkMonitor

• setListeners

  public void setListeners​(java.util.List<? extends StepListener> listeners)

  Register some StepListeners with the handler. Each will get the callbacks in the order specified at the correct stage.

  覆盖:

  setListeners 在类中 JsrChunkProcessor<I,​O>

  参数:

  listeners - listeners to be registered

• registerListener

  public void registerListener​(StepListener listener)

  Register a listener for callbacks at the appropriate stages in a process.

  覆盖:

  registerListener 在类中 JsrChunkProcessor<I,​O>

  参数:

  listener - a StepListener

• provide

  protected I provide​(StepContribution contribution,
                      Chunk<I> chunk)
               throws java.lang.Exception

  Adds retry and skip logic to the reading phase of the chunk loop.

  覆盖:

  provide 在类中 JsrChunkProcessor<I,​O>

  参数:

  contribution - a StepContribution

  chunk - a Chunk

  返回:

  I an item

  抛出:

  java.lang.Exception - thrown if error occurs.

• transform

  protected O transform​(StepContribution contribution,
                        I item)
                 throws java.lang.Exception

  Adds retry and skip logic to the process phase of the chunk loop.

  覆盖:

  transform 在类中 JsrChunkProcessor<I,​O>

  参数:

  contribution - a StepContribution

  item - an item to be processed

  返回:

  O an item that has been processed if a processor is available

  抛出:

  java.lang.Exception - thrown if error occurs.

• persist

  protected void persist​(StepContribution contribution,
                         Chunk<O> chunk)
                  throws java.lang.Exception

  Adds retry and skip logic to the write phase of the chunk loop.

  覆盖:

  persist 在类中 JsrChunkProcessor<I,​O>

  参数:

  contribution - a StepContribution

  chunk - a Chunk

  抛出:

  java.lang.Exception - thrown if error occurs.