public class SkipListenerSupport<T,S> extends Object implements SkipListener<T,S>
SkipListener
implementations.Constructor and Description |
---|
SkipListenerSupport() |
Modifier and Type | Method and Description |
---|---|
void |
onSkipInProcess(T item,
Throwable t)
This item failed on processing with the given exception, and a skip was called
for.
|
void |
onSkipInRead(Throwable t)
Callback for a failure on read that is legal, so is not going to be
re-thrown.
|
void |
onSkipInWrite(S item,
Throwable t)
This item failed on write with the given exception, and a skip was called
for.
|
public void onSkipInRead(Throwable t)
SkipListener
onSkipInRead
in interface SkipListener<T,S>
t
- cause of the failurepublic void onSkipInWrite(S item, Throwable t)
SkipListener
onSkipInWrite
in interface SkipListener<T,S>
item
- the failed itemt
- the cause of the failurepublic void onSkipInProcess(T item, Throwable t)
SkipListener
onSkipInProcess
in interface SkipListener<T,S>
item
- the failed itemt
- the cause of the failureCopyright © 2014 Pivotal. All rights reserved.