|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.springframework.batch.core.listener.MulticasterBatchListener<T,S>
public class MulticasterBatchListener<T,S>
| Constructor Summary | |
|---|---|
MulticasterBatchListener()
Initialise the listener instance. |
|
| Method Summary | |
|---|---|
void |
afterChunk()
Callback after the chunk is executed, but inside the transaction. |
void |
afterProcess(T item,
S result)
Called after ItemProcessor.process(Object) returns. |
void |
afterRead(T item)
Called after ItemReader.read() |
ExitStatus |
afterStep(StepExecution stepExecution)
Give a listener a chance to modify the exit status from a step. |
void |
afterWrite(java.util.List<? extends S> items)
Called after ItemWriter.write(java.util.List) This will be
called before any transaction is committed, and before
ChunkListener.afterChunk() |
void |
beforeChunk()
Callback before the chunk is executed, but inside the transaction. |
void |
beforeProcess(T item)
Called before ItemProcessor.process(Object). |
void |
beforeRead()
Called before ItemReader.read() |
void |
beforeStep(StepExecution stepExecution)
Initialize the state of the listener with the StepExecution from
the current scope. |
void |
beforeWrite(java.util.List<? extends S> items)
Called before ItemWriter.write(java.util.List) |
void |
onProcessError(T item,
java.lang.Exception ex)
Called if an exception was thrown from ItemProcessor.process(Object). |
void |
onReadError(java.lang.Exception ex)
Called if an error occurs while trying to read. |
void |
onSkipInProcess(T item,
java.lang.Throwable t)
This item failed on processing with the given exception, and a skip was called for. |
void |
onSkipInRead(java.lang.Throwable t)
Callback for a failure on read that is legal, so is not going to be re-thrown. |
void |
onSkipInWrite(S item,
java.lang.Throwable t)
This item failed on write with the given exception, and a skip was called for. |
void |
onWriteError(java.lang.Exception ex,
java.util.List<? extends S> items)
Called if an error occurs while trying to write. |
void |
register(StepListener listener)
Register the listener for callbacks on the appropriate interfaces implemented. |
void |
setListeners(java.util.List<? extends StepListener> listeners)
Register each of the objects as listeners. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public MulticasterBatchListener()
| Method Detail |
|---|
public void setListeners(java.util.List<? extends StepListener> listeners)
MulticasterBatchListener broadcast to the individual listeners.
listeners - listener objects of types known to the multicaster.public void register(StepListener listener)
StepListener can be provided, or an
ItemStream. Other types will be ignored.
public void afterProcess(T item,
S result)
ItemProcessListenerItemProcessor.process(Object) returns. If the
processor returns null, this method will still be called, with
a null result, allowing for notification of 'filtered' items.
afterProcess in interface ItemProcessListener<T,S>item - result - CompositeItemProcessListener.afterProcess(java.lang.Object,
java.lang.Object)public void beforeProcess(T item)
ItemProcessListenerItemProcessor.process(Object).
beforeProcess in interface ItemProcessListener<T,S>item - CompositeItemProcessListener.beforeProcess(java.lang.Object)
public void onProcessError(T item,
java.lang.Exception ex)
ItemProcessListenerItemProcessor.process(Object).
onProcessError in interface ItemProcessListener<T,S>item - ex - CompositeItemProcessListener.onProcessError(java.lang.Object,
java.lang.Exception)public ExitStatus afterStep(StepExecution stepExecution)
StepExecutionListenerExitStatus.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 in interface StepExecutionListenerExitStatus to combine with the normal value. Return
null to leave the old value unchanged.CompositeStepExecutionListener.afterStep(StepExecution)public void beforeStep(StepExecution stepExecution)
StepExecutionListenerStepExecution from
the current scope.
beforeStep in interface StepExecutionListenerstepExecution - CompositeStepExecutionListener.beforeStep(org.springframework.batch.core.StepExecution)public void afterChunk()
ChunkListener
afterChunk in interface ChunkListenerCompositeChunkListener.afterChunk()public void beforeChunk()
ChunkListener
beforeChunk in interface ChunkListenerCompositeChunkListener.beforeChunk()public void afterRead(T item)
ItemReadListenerItemReader.read()
afterRead in interface ItemReadListener<T>item - CompositeItemReadListener.afterRead(java.lang.Object)public void beforeRead()
ItemReadListenerItemReader.read()
beforeRead in interface ItemReadListener<T>CompositeItemReadListener.beforeRead()public void onReadError(java.lang.Exception ex)
ItemReadListener
onReadError in interface ItemReadListener<T>ex - CompositeItemReadListener.onReadError(java.lang.Exception)public void afterWrite(java.util.List<? extends S> items)
ItemWriteListenerItemWriter.write(java.util.List) This will be
called before any transaction is committed, and before
ChunkListener.afterChunk()
afterWrite in interface ItemWriteListener<S>items - written itemsItemWriteListener.afterWrite(List)public void beforeWrite(java.util.List<? extends S> items)
ItemWriteListenerItemWriter.write(java.util.List)
beforeWrite in interface ItemWriteListener<S>items - ItemWriteListener.beforeWrite(List)
public void onWriteError(java.lang.Exception ex,
java.util.List<? extends S> items)
ItemWriteListener
onWriteError in interface ItemWriteListener<S>ex - items - ItemWriteListener.onWriteError(Exception, List)public void onSkipInRead(java.lang.Throwable t)
SkipListener
onSkipInRead in interface SkipListener<T,S>t - CompositeSkipListener.onSkipInRead(java.lang.Throwable)
public void onSkipInWrite(S item,
java.lang.Throwable t)
SkipListener
onSkipInWrite in interface SkipListener<T,S>item - t - CompositeSkipListener.onSkipInWrite(java.lang.Object,
java.lang.Throwable)
public void onSkipInProcess(T item,
java.lang.Throwable t)
SkipListener
onSkipInProcess in interface SkipListener<T,S>item - t - CompositeSkipListener.onSkipInProcess(Object, Throwable)
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||