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, publishWithThrowableHeader
public 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>