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, List)
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
ConstructorDescriptionEventEmittingItemWriteListener
(MessagePublisher messagePublisher, int order, TaskEventProperties properties) EventEmittingItemWriteListener
(MessagePublisher messagePublisher, TaskEventProperties properties) -
Method Summary
Modifier and TypeMethodDescriptionvoid
afterWrite
(List items) void
beforeWrite
(List items) int
getOrder()
void
onWriteError
(Exception exception, List items)
-
Constructor Details
-
EventEmittingItemWriteListener
public EventEmittingItemWriteListener(MessagePublisher messagePublisher, TaskEventProperties properties) -
EventEmittingItemWriteListener
public EventEmittingItemWriteListener(MessagePublisher messagePublisher, int order, TaskEventProperties properties)
-
-
Method Details
-
beforeWrite
- Specified by:
beforeWrite
in interfaceorg.springframework.batch.core.ItemWriteListener
-
afterWrite
- 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
-