类 MulticasterBatchListener<T,​S>

构造器详细资料

• MulticasterBatchListener

  public MulticasterBatchListener()

  Initialize the listener instance.

方法详细资料

• setListeners

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

  Register each of the objects as listeners. Once registered, calls to the MulticasterBatchListener broadcast to the individual listeners.

  参数:

  listeners - listener objects of types known to the multicaster.

• register

  public void register​(StepListener listener)

  Register the listener for callbacks on the appropriate interfaces implemented. Any StepListener can be provided, or an ItemStream. Other types will be ignored.

  参数:

  listener - the StepListener instance to be registered.

• 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

  另请参阅:

  CompositeItemProcessListener.afterProcess(java.lang.Object, java.lang.Object)

• beforeProcess

  public void beforeProcess​(T item)

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

  指定者:

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

  参数:

  item - to be processed.

  另请参阅:

  CompositeItemProcessListener.beforeProcess(java.lang.Object)

• onProcessError

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

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

  指定者:

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

  参数:

  item - attempted to be processed

  ex - - exception thrown during processing.

  另请参阅:

  CompositeItemProcessListener.onProcessError(java.lang.Object, java.lang.Exception)

• 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.

  另请参阅:

  CompositeStepExecutionListener.afterStep(StepExecution)

• 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.

  另请参阅:

  CompositeStepExecutionListener.beforeStep(org.springframework.batch.core.StepExecution)

• afterChunk

  public void afterChunk​(ChunkContext context)

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

  指定者:

  afterChunk 在接口中 ChunkListener

  参数:

  context - The current ChunkContext

  另请参阅:

  CompositeChunkListener.afterChunk(ChunkContext context)

• beforeChunk

  public void beforeChunk​(ChunkContext context)

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

  指定者:

  beforeChunk 在接口中 ChunkListener

  参数:

  context - The current ChunkContext

  另请参阅:

  CompositeChunkListener.beforeChunk(ChunkContext context)

• 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()

  另请参阅:

  CompositeItemReadListener.afterRead(java.lang.Object)

• beforeRead

  public void beforeRead()

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

  指定者:

  beforeRead 在接口中 ItemReadListener<T>

  另请参阅:

  CompositeItemReadListener.beforeRead()

• 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

  另请参阅:

  CompositeItemReadListener.onReadError(java.lang.Exception)

• 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

  另请参阅:

  ItemWriteListener.afterWrite(List)

• 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

  另请参阅:

  ItemWriteListener.beforeWrite(List)

• onWriteError

  public void onWriteError​(java.lang.Exception ex,
                           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>

  参数:

  ex - thrown from ItemWriter

  items - attempted to be written.

  另请参阅:

  ItemWriteListener.onWriteError(Exception, List)

• 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

  另请参阅:

  CompositeSkipListener.onSkipInRead(java.lang.Throwable)

• 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

  另请参阅:

  CompositeSkipListener.onSkipInWrite(java.lang.Object, java.lang.Throwable)

• 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

  另请参阅:

  CompositeSkipListener.onSkipInProcess(Object, Throwable)

• 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.

• onRetryReadException

  public void onRetryReadException​(java.lang.Exception ex)
                            throws java.lang.Exception

  指定者:

  onRetryReadException 在接口中 javax.batch.api.chunk.listener.RetryReadListener

  抛出:

  java.lang.Exception

• onRetryProcessException

  public void onRetryProcessException​(java.lang.Object item,
                                      java.lang.Exception ex)
                               throws java.lang.Exception

  指定者:

  onRetryProcessException 在接口中 javax.batch.api.chunk.listener.RetryProcessListener

  抛出:

  java.lang.Exception

• onRetryWriteException

  public void onRetryWriteException​(java.util.List<java.lang.Object> items,
                                    java.lang.Exception ex)
                             throws java.lang.Exception

  指定者:

  onRetryWriteException 在接口中 javax.batch.api.chunk.listener.RetryWriteListener

  抛出:

  java.lang.Exception