T - The type of payload contained in this Messagepublic interface TrackedEventMessage<T> extends EventMessage<T>
EventMessage containing a TrackingToken. The tracking token can be used be event processors to keep track of which events it has processed.| Modifier and Type | Method and Description |
|---|---|
TrackingToken |
trackingToken()
Returns the
TrackingToken of the event message. |
TrackedEventMessage<T> |
withTrackingToken(TrackingToken trackingToken)
Creates a copy of this message with the given
trackingToken to replace the one in this message. |
andMetaData, getIdentifier, getTimestamp, withMetaDatagetMetaData, getPayload, getPayloadType, serializeMetaData, serializePayloadTrackingToken trackingToken()
TrackingToken of the event message.TrackedEventMessage<T> withTrackingToken(TrackingToken trackingToken)
trackingToken to replace the one in this message.
This method is useful in case streams are modified (combined, split), and the tokens of the combined stream are different than the originating stream.
trackingToken - The tracking token to replaceCopyright © 2010–2023. All rights reserved.