Package com.devonfw.module.batch.common.impl

Class ChunkLoggingListener<T,S>

java.lang.Object

com.devonfw.module.batch.common.impl.ChunkLoggingListener<T,S>

Type Parameters:

T - type of the items.

S - type of the results.

All Implemented Interfaces:

org.springframework.batch.core.ItemProcessListener<T,S>, org.springframework.batch.core.ItemReadListener<T>, org.springframework.batch.core.ItemWriteListener<S>, org.springframework.batch.core.SkipListener<T,S>, org.springframework.batch.core.StepListener

public class ChunkLoggingListener<T,S>
extends Object
implements org.springframework.batch.core.SkipListener<T,S>, org.springframework.batch.core.ItemReadListener<T>, org.springframework.batch.core.ItemProcessListener<T,S>, org.springframework.batch.core.ItemWriteListener<S>

Spring Batch listener that logs exceptions together with the item(s) being processed at the time the exceptions occurred.

Field Summary

Fields

Modifier and Type	Field	Description
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
ChunkLoggingListener()

Method Summary

Modifier and Type	Method	Description
void	afterProcess(T item, S result)
void	afterRead(T item)
void	afterWrite(List<? extends S> items)
void	beforeProcess(T item)
void	beforeRead()
void	beforeWrite(List<? extends S> items)
protected String	itemToString(Object item)
void	onProcessError(T item, Exception e)
void	onReadError(Exception e)
void	onSkipInProcess(T item, Throwable t)
void	onSkipInRead(Throwable t)
void	onSkipInWrite(S item, Throwable t)
void	onWriteError(Exception e, List<? extends S> items)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

ChunkLoggingListener

public ChunkLoggingListener()

Method Detail

itemToString

protected String itemToString(Object item)

Parameters:

item - the Object to format.

Returns:

the string representation.

onReadError

public void onReadError(Exception e)

Specified by:

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

onProcessError

public void onProcessError(T item,
                           Exception e)

Specified by:

onProcessError in interface org.springframework.batch.core.ItemProcessListener<T,S>

onWriteError

public void onWriteError(Exception e,
                         List<? extends S> items)

Specified by:

onWriteError in interface org.springframework.batch.core.ItemWriteListener<T>

onSkipInRead

public void onSkipInRead(Throwable t)

Specified by:

onSkipInRead in interface org.springframework.batch.core.SkipListener<T,S>

onSkipInProcess

public void onSkipInProcess(T item,
                            Throwable t)

Specified by:

onSkipInProcess in interface org.springframework.batch.core.SkipListener<T,S>

onSkipInWrite

public void onSkipInWrite(S item,
                          Throwable t)

Specified by:

onSkipInWrite in interface org.springframework.batch.core.SkipListener<T,S>

beforeRead

public void beforeRead()

Specified by:

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

afterRead

public void afterRead(T item)

Specified by:

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

beforeProcess

public void beforeProcess(T item)

Specified by:

beforeProcess in interface org.springframework.batch.core.ItemProcessListener<T,S>

afterProcess

public void afterProcess(T item,
                         S result)

Specified by:

afterProcess in interface org.springframework.batch.core.ItemProcessListener<T,S>

beforeWrite

public void beforeWrite(List<? extends S> items)

Specified by:

beforeWrite in interface org.springframework.batch.core.ItemWriteListener<T>

afterWrite

public void afterWrite(List<? extends S> items)

Specified by:

afterWrite in interface org.springframework.batch.core.ItemWriteListener<T>