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, withMetaData
getMetaData, getPayload, getPayloadType, serializeMetaData, serializePayload
TrackingToken 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–2020. All rights reserved.