类 StepListenerSupport<T,​S>

构造器详细资料

• StepListenerSupport

  public StepListenerSupport()

方法详细资料

• 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

  参数:

  stepExecution - StepExecution instance.

  返回:

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

• beforeStep

  public void beforeStep​(StepExecution stepExecution)

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

  指定者:

  beforeStep 在接口中 StepExecutionListener

  参数:

  stepExecution - instance of StepExecution.

• afterChunk

  public void afterChunk​(ChunkContext context)

  从接口复制的说明: ChunkListener
  Callback after the chunk is executed, outside the transaction.

  指定者:

  afterChunk 在接口中 ChunkListener

  参数:

  context - The current ChunkContext

• beforeChunk

  public void beforeChunk​(ChunkContext context)

  从接口复制的说明: ChunkListener
  Callback before the chunk is executed, but inside the transaction.

  指定者:

  beforeChunk 在接口中 ChunkListener

  参数:

  context - The current ChunkContext

• afterRead

  public void afterRead​(T item)

  从接口复制的说明: ItemReadListener
  Called after ItemReader.read(). This method is called only for actual items (ie it is not called when the reader returns null).

  指定者:

  afterRead 在接口中 ItemReadListener<T>

  参数:

  item - returned from read()

• beforeRead

  public void beforeRead()

  从接口复制的说明: ItemReadListener
  Called before ItemReader.read()

  指定者:

  beforeRead 在接口中 ItemReadListener<T>

• onReadError

  public void onReadError​(java.lang.Exception ex)

  从接口复制的说明: ItemReadListener
  Called if an error occurs while trying to read.

  指定者:

  onReadError 在接口中 ItemReadListener<T>

  参数:

  ex - thrown from ItemWriter

• afterWrite

  public void afterWrite​(java.util.List<? extends S> items)

  从接口复制的说明: ItemWriteListener
  Called after ItemWriter.write(java.util.List) This will be called before any transaction is committed, and before ChunkListener.afterChunk(ChunkContext)

  指定者:

  afterWrite 在接口中 ItemWriteListener<T>

  参数:

  items - written items

• beforeWrite

  public void beforeWrite​(java.util.List<? extends S> items)

  从接口复制的说明: ItemWriteListener
  Called before ItemWriter.write(java.util.List)

  指定者:

  beforeWrite 在接口中 ItemWriteListener<T>

  参数:

  items - to be written

• onWriteError

  public void onWriteError​(java.lang.Exception exception,
                           java.util.List<? extends S> items)

  从接口复制的说明: ItemWriteListener
  Called if an error occurs while trying to write. Will be called inside a transaction, but the transaction will normally be rolled back. There is no way to identify from this callback which of the items (if any) caused the error.

  指定者:

  onWriteError 在接口中 ItemWriteListener<T>

  参数:

  exception - thrown from ItemWriter

  items - attempted to be written.

• afterProcess

  public void afterProcess​(T item,
                           @Nullable
                           S result)

  从接口复制的说明: ItemProcessListener
  Called after ItemProcessor.process(Object) returns. If the processor returns null, this method will still be called, with a {code null} result, allowing for notification of 'filtered' items.

  指定者:

  afterProcess 在接口中 ItemProcessListener<T,​S>

  参数:

  item - to be processed

  result - of processing

• beforeProcess

  public void beforeProcess​(T item)

  从接口复制的说明: ItemProcessListener
  Called before ItemProcessor.process(Object).

  指定者:

  beforeProcess 在接口中 ItemProcessListener<T,​S>

  参数:

  item - to be processed.

• onProcessError

  public void onProcessError​(T item,
                             java.lang.Exception e)

  从接口复制的说明: ItemProcessListener
  Called if an exception was thrown from ItemProcessor.process(Object).

  指定者:

  onProcessError 在接口中 ItemProcessListener<T,​S>

  参数:

  item - attempted to be processed

  e - - exception thrown during processing.

• onSkipInProcess

  public void onSkipInProcess​(T item,
                              java.lang.Throwable t)

  从接口复制的说明: SkipListener
  This item failed on processing with the given exception, and a skip was called for.

  指定者:

  onSkipInProcess 在接口中 SkipListener<T,​S>

  参数:

  item - the failed item

  t - the cause of the failure

• onSkipInRead

  public void onSkipInRead​(java.lang.Throwable t)

  从接口复制的说明: SkipListener
  Callback for a failure on read that is legal, so is not going to be re-thrown. In case transaction is rolled back and items are re-read, this callback will occur repeatedly for the same cause. This will only happen if read items are not buffered.

  指定者:

  onSkipInRead 在接口中 SkipListener<T,​S>

  参数:

  t - cause of the failure

• onSkipInWrite

  public void onSkipInWrite​(S item,
                            java.lang.Throwable t)

  从接口复制的说明: SkipListener
  This item failed on write with the given exception, and a skip was called for.

  指定者:

  onSkipInWrite 在接口中 SkipListener<T,​S>

  参数:

  item - the failed item

  t - the cause of the failure

• afterChunkError

  public void afterChunkError​(ChunkContext context)

  从接口复制的说明: ChunkListener
  Callback after a chunk has been marked for rollback. It is invoked after transaction rollback. While the rollback will have occurred, transactional resources might still be active and accessible. Due to this, data access code within this callback will still "participate" in the original transaction unless it declares that it runs in its own transaction. Hence: Use PROPAGATION_REQUIRES_NEW for any transactional operation that is called from here.

  指定者:

  afterChunkError 在接口中 ChunkListener

  参数:

  context - the chunk context containing the exception that caused the underlying rollback.