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)