org.springframework.xd.dirt.plugins.job.support.listener

Class SimpleXdItemListener<I,O>

java.lang.Object

org.springframework.xd.dirt.plugins.job.support.listener.BatchJobListener<java.lang.Object>

org.springframework.xd.dirt.plugins.job.support.listener.SimpleXdItemListener<I,O>

All Implemented Interfaces:

org.springframework.batch.core.ItemProcessListener<I,java.lang.Object>, org.springframework.batch.core.ItemReadListener<I>, org.springframework.batch.core.ItemWriteListener<java.lang.Object>, org.springframework.batch.core.StepListener

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>

Since:

1.0

Author:

Gunnar Hillert, Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description
SimpleXdItemListener(org.springframework.messaging.SubscribableChannel itemEventsChannel, org.springframework.messaging.SubscribableChannel aggregatedEventsChannel)

Method Summary

Methods

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)

Methods inherited from class org.springframework.xd.dirt.plugins.job.support.listener.BatchJobListener

publish, publishWithThrowableHeader

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleXdItemListener

public SimpleXdItemListener(org.springframework.messaging.SubscribableChannel itemEventsChannel,
                    org.springframework.messaging.SubscribableChannel aggregatedEventsChannel)

Method Detail

onReadError

public void onReadError(java.lang.Exception exception)

Specified by:

onReadError in interface org.springframework.batch.core.ItemReadListener<I>

onProcessError

public void onProcessError(I item,
                  java.lang.Exception exception)

Specified by:

onProcessError in interface org.springframework.batch.core.ItemProcessListener<I,java.lang.Object>

afterWrite

public void afterWrite(java.util.List<? extends java.lang.Object> items)

Specified by:

afterWrite in interface org.springframework.batch.core.ItemWriteListener<java.lang.Object>

onWriteError

public void onWriteError(java.lang.Exception exception,
                java.util.List<? extends java.lang.Object> items)

Specified by:

onWriteError in interface org.springframework.batch.core.ItemWriteListener<java.lang.Object>

beforeWrite

public void beforeWrite(java.util.List<? extends java.lang.Object> items)

Specified by:

beforeWrite in interface org.springframework.batch.core.ItemWriteListener<java.lang.Object>

beforeProcess

public void beforeProcess(I item)

Specified by:

beforeProcess in interface org.springframework.batch.core.ItemProcessListener<I,java.lang.Object>

afterProcess

public void afterProcess(I item,
                java.lang.Object result)

Specified by:

afterProcess in interface org.springframework.batch.core.ItemProcessListener<I,java.lang.Object>

beforeRead

public void beforeRead()

Specified by:

beforeRead in interface org.springframework.batch.core.ItemReadListener<I>

afterRead

public void afterRead(I item)

Specified by:

afterRead in interface org.springframework.batch.core.ItemReadListener<I>