public final class SimpleXdItemListener<I,O> extends BatchJobListener<java.lang.Object> implements org.springframework.batch.core.ItemReadListener<I>, org.springframework.batch.core.ItemProcessListener<I,java.lang.Object>, org.springframework.batch.core.ItemWriteListener<java.lang.Object>
| Constructor and Description |
|---|
SimpleXdItemListener(org.springframework.messaging.SubscribableChannel itemEventsChannel,
org.springframework.messaging.SubscribableChannel aggregatedEventsChannel) |
| Modifier and Type | Method and Description |
|---|---|
void |
afterProcess(I item,
java.lang.Object result) |
void |
afterRead(I item) |
void |
afterWrite(java.util.List<? extends java.lang.Object> items) |
void |
beforeProcess(I item) |
void |
beforeRead() |
void |
beforeWrite(java.util.List<? extends java.lang.Object> items) |
void |
onProcessError(I item,
java.lang.Exception exception) |
void |
onReadError(java.lang.Exception exception) |
void |
onWriteError(java.lang.Exception exception,
java.util.List<? extends java.lang.Object> items) |
publish, publishWithThrowableHeaderpublic SimpleXdItemListener(org.springframework.messaging.SubscribableChannel itemEventsChannel,
org.springframework.messaging.SubscribableChannel aggregatedEventsChannel)
public void onReadError(java.lang.Exception exception)
onReadError in interface org.springframework.batch.core.ItemReadListener<I>public void onProcessError(I item, java.lang.Exception exception)
onProcessError in interface org.springframework.batch.core.ItemProcessListener<I,java.lang.Object>public void afterWrite(java.util.List<? extends java.lang.Object> items)
afterWrite in interface org.springframework.batch.core.ItemWriteListener<java.lang.Object>public void onWriteError(java.lang.Exception exception,
java.util.List<? extends java.lang.Object> items)
onWriteError in interface org.springframework.batch.core.ItemWriteListener<java.lang.Object>public void beforeWrite(java.util.List<? extends java.lang.Object> items)
beforeWrite in interface org.springframework.batch.core.ItemWriteListener<java.lang.Object>public void beforeProcess(I item)
beforeProcess in interface org.springframework.batch.core.ItemProcessListener<I,java.lang.Object>public void afterProcess(I item, java.lang.Object result)
afterProcess in interface org.springframework.batch.core.ItemProcessListener<I,java.lang.Object>public void beforeRead()
beforeRead in interface org.springframework.batch.core.ItemReadListener<I>