public class CompositeSkipListener<T,S> extends java.lang.Object implements SkipListener<T,S>
Constructor and Description |
---|
CompositeSkipListener() |
Modifier and Type | Method and Description |
---|---|
void |
onSkipInProcess(T item,
java.lang.Throwable t)
Call the registered listeners in order, respecting and prioritising those
that implement
Ordered . |
void |
onSkipInRead(java.lang.Throwable t)
Call the registered listeners in order, respecting and prioritising those
that implement
Ordered . |
void |
onSkipInWrite(S item,
java.lang.Throwable t)
Call the registered listeners in order, respecting and prioritising those
that implement
Ordered . |
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.
|
public void setListeners(java.util.List<? extends SkipListener<? super T,? super S>> listeners)
listeners
- public void register(SkipListener<? super T,? super S> listener)
listener
- public void onSkipInRead(java.lang.Throwable t)
Ordered
.onSkipInRead
in interface SkipListener<T,S>
t
- cause of the failureSkipListener.onSkipInRead(java.lang.Throwable)
public void onSkipInWrite(S item, java.lang.Throwable t)
Ordered
.onSkipInWrite
in interface SkipListener<T,S>
item
- the failed itemt
- the cause of the failureSkipListener.onSkipInWrite(java.lang.Object,
java.lang.Throwable)
public void onSkipInProcess(T item, java.lang.Throwable t)
Ordered
.onSkipInProcess
in interface SkipListener<T,S>
item
- the failed itemt
- the cause of the failureSkipListener.onSkipInWrite(java.lang.Object,
java.lang.Throwable)