Class CompositeSkipListener<T,S>
- java.lang.Object
- org.springframework.batch.core.listener.CompositeSkipListener<T,S>
- All Implemented Interfaces:
SkipListener<T,S>
,StepListener
public class CompositeSkipListener<T,S> extends java.lang.Object implements SkipListener<T,S>
- Author:
- Dave Syer
Constructor Summary
Constructors Constructor Description CompositeSkipListener()
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onSkipInProcess(T item, java.lang.Throwable t)
Call the registered listeners in order, respecting and prioritising those that implementOrdered
.void
onSkipInRead(java.lang.Throwable t)
Call the registered listeners in order, respecting and prioritising those that implementOrdered
.void
onSkipInWrite(S item, java.lang.Throwable t)
Call the registered listeners in order, respecting and prioritising those that implementOrdered
.void
register(SkipListener<? super T,? super S> listener)
Register additional listener.void
setListeners(java.util.List<? extends SkipListener<? super T,? super S>> listeners)
Public setter for the listeners.
Method Detail
setListeners
public void setListeners(java.util.List<? extends SkipListener<? super T,? super S>> listeners)
Public setter for the listeners.- Parameters:
listeners
- list ofSkipListener
s to be called when skip events occur.
register
public void register(SkipListener<? super T,? super S> listener)
Register additional listener.- Parameters:
listener
- instance ofSkipListener
to be registered.
onSkipInRead
public void onSkipInRead(java.lang.Throwable t)
Call the registered listeners in order, respecting and prioritising those that implementOrdered
.- Specified by:
onSkipInRead
in interfaceSkipListener<T,S>
- Parameters:
t
- cause of the failure- See Also:
SkipListener.onSkipInRead(java.lang.Throwable)
onSkipInWrite
public void onSkipInWrite(S item, java.lang.Throwable t)
Call the registered listeners in order, respecting and prioritising those that implementOrdered
.- Specified by:
onSkipInWrite
in interfaceSkipListener<T,S>
- Parameters:
item
- the failed itemt
- the cause of the failure- See Also:
SkipListener.onSkipInWrite(java.lang.Object, java.lang.Throwable)
onSkipInProcess
public void onSkipInProcess(T item, java.lang.Throwable t)
Call the registered listeners in order, respecting and prioritising those that implementOrdered
.- Specified by:
onSkipInProcess
in interfaceSkipListener<T,S>
- Parameters:
item
- the failed itemt
- the cause of the failure- See Also:
SkipListener.onSkipInWrite(java.lang.Object, java.lang.Throwable)