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 TypeMethodDescriptionvoid
afterWrite
(org.springframework.batch.item.Chunk items) void
beforeWrite
(org.springframework.batch.item.Chunk items) int
getOrder()
void
onWriteError
(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:
beforeWrite
in interfaceorg.springframework.batch.core.ItemWriteListener
-
afterWrite
public void afterWrite(org.springframework.batch.item.Chunk items) - Specified by:
afterWrite
in interfaceorg.springframework.batch.core.ItemWriteListener
-
onWriteError
- Specified by:
onWriteError
in interfaceorg.springframework.batch.core.ItemWriteListener
-
getOrder
public int getOrder()- Specified by:
getOrder
in interfaceorg.springframework.core.Ordered
-