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

Class SimpleXdSkipListener

java.lang.Object

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

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

All Implemented Interfaces:

org.springframework.batch.core.SkipListener<java.lang.Object,java.lang.Object>, org.springframework.batch.core.StepListener

public class SimpleXdSkipListener
extends BatchJobListener<java.lang.Object>
implements org.springframework.batch.core.SkipListener<java.lang.Object,java.lang.Object>

Since:

1.0

Author:

Gunnar Hillert, Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description
SimpleXdSkipListener(org.springframework.messaging.SubscribableChannel skipEventsChannel, org.springframework.messaging.SubscribableChannel aggregatedEventsChannel)

Method Summary

Methods

Modifier and Type	Method and Description
void	onSkipInProcess(java.lang.Object item, java.lang.Throwable t)
void	onSkipInRead(java.lang.Throwable t)
void	onSkipInWrite(java.lang.Object item, java.lang.Throwable t)

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

SimpleXdSkipListener

public SimpleXdSkipListener(org.springframework.messaging.SubscribableChannel skipEventsChannel,
                    org.springframework.messaging.SubscribableChannel aggregatedEventsChannel)

Method Detail

onSkipInRead

public void onSkipInRead(java.lang.Throwable t)

Specified by:

onSkipInRead in interface org.springframework.batch.core.SkipListener<java.lang.Object,java.lang.Object>

onSkipInWrite

public void onSkipInWrite(java.lang.Object item,
                 java.lang.Throwable t)

Specified by:

onSkipInWrite in interface org.springframework.batch.core.SkipListener<java.lang.Object,java.lang.Object>

onSkipInProcess

public void onSkipInProcess(java.lang.Object item,
                   java.lang.Throwable t)

Specified by:

onSkipInProcess in interface org.springframework.batch.core.SkipListener<java.lang.Object,java.lang.Object>