public class MulticasterBatchListener<T,S> extends java.lang.Object implements StepExecutionListener, ChunkListener, ItemReadListener<T>, ItemProcessListener<T,S>, ItemWriteListener<S>, SkipListener<T,S>, javax.batch.api.chunk.listener.RetryReadListener, javax.batch.api.chunk.listener.RetryProcessListener, javax.batch.api.chunk.listener.RetryWriteListener
ROLLBACK_EXCEPTION_KEY
コンストラクターと説明 |
---|
MulticasterBatchListener() リスナーインスタンスを初期化します。 |
修飾子と型 | メソッドと説明 |
---|---|
void | afterChunk(ChunkContext context) トランザクションの外部で、チャンクが実行された後のコールバック。 |
void | afterChunkError(ChunkContext context) チャンクがロールバック用にマークされた後のコールバック。 |
void | afterProcess(T item, S result) ItemProcessor.process(Object) が戻った後に呼び出されます。 |
void | afterRead(T item) ItemReader.read() の後に呼び出されます。 |
ExitStatus | afterStep(StepExecution stepExecution) リスナーにステップの終了ステータスを変更する機会を与えます。 |
void | afterWrite(java.util.List<? extends S> items) ItemWriter.write(java.util.List) の後に呼び出されるこれは、トランザクションがコミットされる前、および ChunkListener.afterChunk(ChunkContext) の前に呼び出されます |
void | beforeChunk(ChunkContext context) チャンクが実行される前の、トランザクション内のコールバック。 |
void | beforeProcess(T item) ItemProcessor.process(Object) の前に呼び出されます。 |
void | beforeRead() ItemReader.read() の前に呼び出されます |
void | beforeStep(StepExecution stepExecution) 現在のスコープの StepExecution を使用して、リスナーの状態を初期化します。 |
void | beforeWrite(java.util.List<? extends S> items) ItemWriter.write(java.util.List) の前に呼び出されます |
void | onProcessError(T item, java.lang.Exception ex) ItemProcessor.process(Object) から例外がスローされた場合に呼び出されます。 |
void | onReadError(java.lang.Exception ex) 読み取りの試行中にエラーが発生した場合に呼び出されます。 |
void | onRetryProcessException(java.lang.Object item, java.lang.Exception ex) |
void | onRetryReadException(java.lang.Exception ex) |
void | onRetryWriteException(java.util.List<java.lang.Object> items, java.lang.Exception ex) |
void | onSkipInProcess(T item, java.lang.Throwable t) このアイテムは、指定された例外で処理に失敗し、スキップが要求されました。 |
void | onSkipInRead(java.lang.Throwable t) 読み取りの失敗に対するコールバックは正当であるため、再スローされません。 |
void | onSkipInWrite(S item, java.lang.Throwable t) この項目は、指定された例外で書き込み時に失敗し、スキップが要求されました。 |
void | onWriteError(java.lang.Exception ex, java.util.List<? extends S> items) 書き込みの試行中にエラーが発生した場合に呼び出されます。 |
void | register(StepListener listener) 実装された適切なインターフェースでコールバックのリスナーを登録します。 |
void | setListeners(java.util.List<? extends StepListener> listeners) 各オブジェクトをリスナーとして登録します。 |
public void setListeners(java.util.List<? extends StepListener> listeners)
MulticasterBatchListener
の呼び出しは個々のリスナーにブロードキャストされます。listeners
- マルチキャスターに知られている型のリスナーオブジェクト。public void register(StepListener listener)
StepListener
または ItemStream
を提供できます。他の型は無視されます。listener
- 登録する StepListener
インスタンス。public void afterProcess(T item, @Nullable S result)
ItemProcessListener
ItemProcessor.process(Object)
が戻った後に呼び出されます。プロセッサーが null
を返す場合、このメソッドは {code null} の結果で呼び出され、「フィルター済み」アイテムの通知が可能になります。ItemProcessListener<T, S>
の afterProcess
item
- 処理される result
- 処理 CompositeItemProcessListener.afterProcess(java.lang.Object, java.lang.Object)
public void beforeProcess(T item)
ItemProcessListener
ItemProcessor.process(Object)
の前に呼び出されます。ItemProcessListener<T, S>
の beforeProcess
item
- 処理されます。CompositeItemProcessListener.beforeProcess(java.lang.Object)
public void onProcessError(T item, java.lang.Exception ex)
ItemProcessListener
ItemProcessor.process(Object)
から例外がスローされた場合に呼び出されます。ItemProcessListener<T, S>
の onProcessError
item
- 処理しようとしました ex
- - 処理中にスローされた例外。CompositeItemProcessListener.onProcessError(java.lang.Object, java.lang.Exception)
@Nullable public ExitStatus afterStep(StepExecution stepExecution)
StepExecutionListener
ExitStatus.and(ExitStatus)
を使用して通常の終了ステータスと結合されます。ステップの処理ロジックの実行後に呼び出されます(成功または失敗の両方)。このメソッドで例外をスローしても効果はなく、ログに記録されるだけです。StepExecutionListener
の afterStep
stepExecution
- StepExecution
インスタンス。ExitStatus
。null
を返し、古い値を変更せずに残します。CompositeStepExecutionListener.afterStep(StepExecution)
public void beforeStep(StepExecution stepExecution)
StepExecutionListener
StepExecution
を使用して、リスナーの状態を初期化します。StepExecutionListener
の beforeStep
stepExecution
- StepExecution
のインスタンス。CompositeStepExecutionListener.beforeStep(org.springframework.batch.core.StepExecution)
public void afterChunk(ChunkContext context)
ChunkListener
ChunkListener
の afterChunk
context
- 現在の ChunkContext
CompositeChunkListener.afterChunk(ChunkContext context)
public void beforeChunk(ChunkContext context)
ChunkListener
ChunkListener
の beforeChunk
context
- 現在の ChunkContext
CompositeChunkListener.beforeChunk(ChunkContext context)
public void afterRead(T item)
ItemReadListener
ItemReader.read()
の後に呼び出されます。このメソッドは、実際のアイテムに対してのみ呼び出されます(つまり、リーダーが null を返す場合は呼び出されません)。ItemReadListener<T>
の afterRead
item
- read() から返された CompositeItemReadListener.afterRead(java.lang.Object)
public void beforeRead()
ItemReadListener
ItemReader.read()
の前に呼び出されます ItemReadListener<T>
の beforeRead
CompositeItemReadListener.beforeRead()
public void onReadError(java.lang.Exception ex)
ItemReadListener
ItemReadListener<T>
の onReadError
ex
- ItemReader
からスロー CompositeItemReadListener.onReadError(java.lang.Exception)
public void afterWrite(java.util.List<? extends S> items)
ItemWriteListener
ItemWriter.write(java.util.List)
の後に呼び出されるこれは、トランザクションがコミットされる前、および ChunkListener.afterChunk(ChunkContext)
の前に呼び出されます ItemWriteListener<S>
の afterWrite
items
- 書かれたアイテム ItemWriteListener.afterWrite(List)
public void beforeWrite(java.util.List<? extends S> items)
ItemWriteListener
ItemWriter.write(java.util.List)
の前に呼び出されます ItemWriteListener<S>
の beforeWrite
items
- 書かれる ItemWriteListener.beforeWrite(List)
public void onWriteError(java.lang.Exception ex, java.util.List<? extends S> items)
ItemWriteListener
ItemWriteListener<S>
の onWriteError
ex
- ItemWriter
からスロー items
- 書こうとしました。ItemWriteListener.onWriteError(Exception, List)
public void onSkipInRead(java.lang.Throwable t)
SkipListener
SkipListener<T, S>
の onSkipInRead
t
- 失敗の原因 CompositeSkipListener.onSkipInRead(java.lang.Throwable)
public void onSkipInWrite(S item, java.lang.Throwable t)
SkipListener
SkipListener<T, S>
の onSkipInWrite
item
- 失敗したアイテム t
- 失敗の原因 CompositeSkipListener.onSkipInWrite(java.lang.Object, java.lang.Throwable)
public void onSkipInProcess(T item, java.lang.Throwable t)
SkipListener
SkipListener<T, S>
の onSkipInProcess
item
- 失敗したアイテム t
- 失敗の原因 CompositeSkipListener.onSkipInProcess(Object, Throwable)
public void afterChunkError(ChunkContext context)
ChunkListener
ChunkListener
の afterChunkError
context
- 基になるロールバックを引き起こした例外を含むチャンクコンテキスト。public void onRetryReadException(java.lang.Exception ex) throws java.lang.Exception
javax.batch.api.chunk.listener.RetryReadListener
の onRetryReadException
java.lang.Exception
public void onRetryProcessException(java.lang.Object item, java.lang.Exception ex) throws java.lang.Exception
javax.batch.api.chunk.listener.RetryProcessListener
の onRetryProcessException
java.lang.Exception
public void onRetryWriteException(java.util.List<java.lang.Object> items, java.lang.Exception ex) throws java.lang.Exception
javax.batch.api.chunk.listener.RetryWriteListener
の onRetryWriteException
java.lang.Exception