Class EventEmittingItemWriteListener
java.lang.Object
org.springframework.cloud.task.batch.listener.EventEmittingItemWriteListener
- All Implemented Interfaces:
org.springframework.batch.core.ItemWriteListener,org.springframework.batch.core.StepListener,org.springframework.core.Ordered
public class EventEmittingItemWriteListener
extends Object
implements org.springframework.batch.core.ItemWriteListener, org.springframework.core.Ordered
Setups up the ItemWriteEventsListener to emit events to the spring cloud stream output
channel.
Each method provides an informational message.
ItemWriteListener.onWriteError(Exception, Chunk) provides a message as well as
the exception's message via the BatchJobHeaders.BATCH_EXCEPTION message header.- Author:
- Glenn Renfro, Ali Shahbour
-
Field Summary
Fields inherited from interface org.springframework.core.Ordered
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE -
Constructor Summary
ConstructorsConstructorDescriptionEventEmittingItemWriteListener(MessagePublisher messagePublisher, int order, TaskEventProperties properties) EventEmittingItemWriteListener(MessagePublisher messagePublisher, TaskEventProperties properties) -
Method Summary
Modifier and TypeMethodDescriptionvoidafterWrite(org.springframework.batch.item.Chunk items) voidbeforeWrite(org.springframework.batch.item.Chunk items) intgetOrder()voidonWriteError(Exception exception, org.springframework.batch.item.Chunk items)
-
Constructor Details
-
EventEmittingItemWriteListener
public EventEmittingItemWriteListener(MessagePublisher messagePublisher, TaskEventProperties properties) -
EventEmittingItemWriteListener
public EventEmittingItemWriteListener(MessagePublisher messagePublisher, int order, TaskEventProperties properties)
-
-
Method Details
-
beforeWrite
public void beforeWrite(org.springframework.batch.item.Chunk items) - Specified by:
beforeWritein interfaceorg.springframework.batch.core.ItemWriteListener
-
afterWrite
public void afterWrite(org.springframework.batch.item.Chunk items) - Specified by:
afterWritein interfaceorg.springframework.batch.core.ItemWriteListener
-
onWriteError
- Specified by:
onWriteErrorin interfaceorg.springframework.batch.core.ItemWriteListener
-
getOrder
public int getOrder()- Specified by:
getOrderin interfaceorg.springframework.core.Ordered
-