Modifier and Type | Method and Description |
---|---|
TrackingToken |
TrackedEventMessage.trackingToken()
Returns the
TrackingToken of the event message. |
TrackingToken |
GenericTrackedEventMessage.trackingToken() |
Modifier and Type | Method and Description |
---|---|
TrackingEventStream |
SimpleEventBus.openStream(TrackingToken trackingToken)
This implementation only returns a stream if the specified
trackingToken is null . |
TrackingEventStream |
EventBus.openStream(TrackingToken trackingToken)
Open an event stream containing all events since given tracking token.
|
Constructor and Description |
---|
GenericTrackedEventMessage(TrackingToken trackingToken,
EventMessage<T> delegate)
Creates a GenericTrackedEventMessage with given
trackingToken and delegate event message. |
GenericTrackedEventMessage(TrackingToken trackingToken,
Message<T> delegate,
Instant timestamp)
Initializes a
GenericTrackedEventMessage with given message as delegate and given timestamp . |
GenericTrackedEventMessage(TrackingToken trackingToken,
Message<T> delegate,
Supplier<Instant> timestamp)
Creates a GenericTrackedEventMessage with given
trackingToken and delegate event message. |
Modifier and Type | Method and Description |
---|---|
TrackingToken |
Saga.trackingToken()
Returns the TrackingToken belonging to the EventMessage last processed by this instance, or
null if
this instance never handled an EventMessage, or if it received an EventMessage that doesn't carry a
TrackingToken. |
TrackingToken |
AnnotatedSaga.trackingToken() |
Constructor and Description |
---|
AnnotatedSaga(String sagaId,
Set<AssociationValue> associationValues,
T annotatedSaga,
TrackingToken trackingToken,
SagaModel<T> metaModel)
Creates an AnnotatedSaga instance to wrap the given
annotatedSaga , identifier with the given
sagaId and associated with the given associationValues . |
Modifier and Type | Method and Description |
---|---|
TrackingToken |
SagaStore.Entry.trackingToken()
Returns the tracking token of the last event handled by the Saga.
|
Modifier and Type | Method and Description |
---|---|
void |
SagaStore.insertSaga(Class<? extends T> sagaType,
String sagaIdentifier,
T saga,
TrackingToken token,
Set<AssociationValue> associationValues)
Adds a new Saga and its initial association values to the store.
|
void |
CachingSagaStore.insertSaga(Class<? extends T> sagaType,
String sagaIdentifier,
T saga,
TrackingToken token,
Set<AssociationValue> associationValues) |
void |
SagaStore.updateSaga(Class<? extends T> sagaType,
String sagaIdentifier,
T saga,
TrackingToken token,
AssociationValues associationValues)
Updates a given Saga after its state was modified.
|
void |
CachingSagaStore.updateSaga(Class<? extends T> sagaType,
String sagaIdentifier,
T saga,
TrackingToken token,
AssociationValues associationValues) |
Modifier and Type | Method and Description |
---|---|
void |
InMemorySagaStore.insertSaga(Class<?> sagaType,
String sagaIdentifier,
Object saga,
TrackingToken token,
Set<AssociationValue> associationValues) |
void |
InMemorySagaStore.updateSaga(Class<?> sagaType,
String sagaIdentifier,
Object saga,
TrackingToken token,
AssociationValues associationValues) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcSagaStore.insertSaga(Class<?> sagaType,
String sagaIdentifier,
Object saga,
TrackingToken token,
Set<AssociationValue> associationValues) |
void |
JdbcSagaStore.updateSaga(Class<?> sagaType,
String sagaIdentifier,
Object saga,
TrackingToken token,
AssociationValues associationValues) |
Modifier and Type | Method and Description |
---|---|
void |
JpaSagaStore.insertSaga(Class<?> sagaType,
String sagaIdentifier,
Object saga,
TrackingToken token,
Set<AssociationValue> associationValues) |
void |
JpaSagaStore.updateSaga(Class<?> sagaType,
String sagaIdentifier,
Object saga,
TrackingToken token,
AssociationValues associationValues) |
Modifier and Type | Method and Description |
---|---|
TrackingToken |
TokenStore.fetchToken(String processorName,
int segment)
|
TrackingToken |
AbstractTokenEntry.getToken(Serializer serializer)
Returns the token, deserializing it with given
serializer |
Modifier and Type | Method and Description |
---|---|
void |
TokenStore.storeToken(TrackingToken token,
String processorName,
int segment)
Stores the given
token in the store. |
void |
GenericTokenEntry.updateToken(TrackingToken token,
Serializer serializer) |
abstract void |
AbstractTokenEntry.updateToken(TrackingToken token,
Serializer serializer)
Update this entry with the given
token , serializing it using given serializer . |
protected void |
AbstractTokenEntry.updateToken(TrackingToken token,
Serializer serializer,
Class<T> contentType)
Update the token data to the given
token , using given serializer to serialize it to the given
contentType . |
Constructor and Description |
---|
AbstractTokenEntry(TrackingToken token,
Serializer serializer,
Class<T> contentType)
Initializes a new token entry for given
token , process and segment . |
GenericTokenEntry(TrackingToken token,
Serializer serializer,
Class<T> contentType,
String processorName,
int segment)
Initializes a new token entry for given
token , process and segment . |
Modifier and Type | Method and Description |
---|---|
TrackingToken |
InMemoryTokenStore.fetchToken(String processorName,
int segment) |
Modifier and Type | Method and Description |
---|---|
void |
InMemoryTokenStore.storeToken(TrackingToken token,
String processorName,
int segment) |
Modifier and Type | Method and Description |
---|---|
protected TrackingToken |
JdbcTokenStore.claimToken(ResultSet resultSet,
AbstractTokenEntry<?> entry)
Tries to claim the given token
entry . |
TrackingToken |
JdbcTokenStore.fetchToken(String processorName,
int segment) |
protected TrackingToken |
JdbcTokenStore.insertTokenEntry(ResultSet resultSet,
TrackingToken token,
String processorName,
int segment)
Inserts a new token entry via the given updatable
resultSet . |
protected TrackingToken |
JdbcTokenStore.loadOrInsertToken(ResultSet resultSet,
String processorName,
int segment)
Tries loading an existing token owned by a processor with given
processorName and segment . |
Modifier and Type | Method and Description |
---|---|
protected void |
JdbcTokenStore.insertOrUpdateToken(ResultSet resultSet,
TrackingToken token,
String processorName,
int segment)
If the given
resultSet has no items this method should insert a new token entry. |
protected TrackingToken |
JdbcTokenStore.insertTokenEntry(ResultSet resultSet,
TrackingToken token,
String processorName,
int segment)
Inserts a new token entry via the given updatable
resultSet . |
void |
JdbcTokenStore.storeToken(TrackingToken token,
String processorName,
int segment) |
Modifier and Type | Method and Description |
---|---|
TrackingToken |
JpaTokenStore.fetchToken(String processorName,
int segment) |
Modifier and Type | Method and Description |
---|---|
void |
JpaTokenStore.storeToken(TrackingToken token,
String processorName,
int segment) |
void |
TokenEntry.updateToken(TrackingToken token,
Serializer serializer) |
Constructor and Description |
---|
TokenEntry(String processorName,
int segment,
TrackingToken token,
Serializer serializer)
Initializes a new token entry for given
token , processorName and segment . |
Modifier and Type | Method and Description |
---|---|
TrackingToken |
GenericTrackedDomainEventMessage.trackingToken() |
Modifier and Type | Method and Description |
---|---|
Stream<? extends TrackedEventMessage<?>> |
FilteringEventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock) |
Constructor and Description |
---|
GenericTrackedDomainEventMessage(TrackingToken trackingToken,
DomainEventMessage<T> delegate)
Initialize a DomainEventMessage originating from an aggregate.
|
GenericTrackedDomainEventMessage(TrackingToken trackingToken,
String type,
String aggregateIdentifier,
long sequenceNumber,
Message<T> delegate,
Instant timestamp)
Initialize a DomainEventMessage originating from an aggregate.
|
GenericTrackedDomainEventMessage(TrackingToken trackingToken,
String type,
String aggregateIdentifier,
long sequenceNumber,
Message<T> delegate,
Supplier<Instant> timestamp)
Initialize a DomainEventMessage originating from an Aggregate using existing data.
|
Modifier and Type | Class and Description |
---|---|
class |
GapAwareTrackingToken
Implementation of a
TrackingToken that uses the global insertion sequence number of the event to determine
tracking order and additionally stores a set of possible gaps that have been detected while tracking the event
store. |
class |
GlobalSequenceTrackingToken
Tracking token based on the global sequence number of an event.
|
Modifier and Type | Method and Description |
---|---|
TrackingToken |
TrackedEventData.trackingToken()
Returns the
TrackingToken of the serialized event. |
TrackingToken |
TrackedDomainEventData.trackingToken() |
TrackingToken |
GenericTrackedDomainEventEntry.trackingToken()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static <T> TrackedEventMessage<T> |
EventUtils.asTrackedEventMessage(EventMessage<T> eventMessage,
TrackingToken trackingToken)
|
protected abstract List<? extends TrackedEventData<?>> |
BatchingEventStorageEngine.fetchTrackedEvents(TrackingToken lastToken,
int batchSize)
Returns a batch of serialized event data entries in the event storage that have a
TrackingToken greater
than the given lastToken . |
TrackingEventStream |
EmbeddedEventStore.openStream(TrackingToken trackingToken) |
protected Stream<? extends TrackedEventData<?>> |
BatchingEventStorageEngine.readEventData(TrackingToken trackingToken,
boolean mayBlock)
Returns a global
Stream containing all serialized event data entries in the event storage that have a
TrackingToken greater than the given trackingToken . |
protected abstract Stream<? extends TrackedEventData<?>> |
AbstractEventStorageEngine.readEventData(TrackingToken trackingToken,
boolean mayBlock)
Returns a global
Stream containing all serialized event data entries in the event storage that have a
TrackingToken greater than the given trackingToken . |
Stream<? extends TrackedEventMessage<?>> |
SequenceEventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock) |
Stream<? extends TrackedEventMessage<?>> |
EventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock)
Open an event stream containing all events stored since given tracking token.
|
Stream<? extends TrackedEventMessage<?>> |
AbstractEventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock) |
Constructor and Description |
---|
GenericTrackedDomainEventEntry(TrackingToken trackingToken,
String type,
String aggregateIdentifier,
long sequenceNumber,
String eventIdentifier,
Object timestamp,
String payloadType,
String payloadRevision,
T payload,
T metaData)
Deprecated.
Reconstruct an event entry from a stored object.
|
TrackedDomainEventData(TrackingToken trackingToken,
DomainEventData<T> domainEventEntry)
Initialize the TrackingDomainEventData with given
trackingToken and domainEventEntry . |
Modifier and Type | Method and Description |
---|---|
Stream<? extends TrackedEventMessage<?>> |
InMemoryEventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock)
Open an event stream containing all events stored since given tracking token.
|
Modifier and Type | Method and Description |
---|---|
protected List<? extends TrackedEventData<?>> |
JdbcEventStorageEngine.fetchTrackedEvents(TrackingToken lastToken,
int batchSize) |
protected PreparedStatement |
JdbcEventStorageEngine.readEventData(Connection connection,
TrackingToken lastToken,
int batchSize)
Creates a statement to read tracked event entries stored since given tracking token.
|
Modifier and Type | Method and Description |
---|---|
protected List<? extends TrackedEventData<?>> |
JpaEventStorageEngine.fetchTrackedEvents(TrackingToken lastToken,
int batchSize) |
Modifier and Type | Method and Description |
---|---|
MessageStream<M> |
StreamableMessageSource.openStream(TrackingToken trackingToken)
Open a stream containing all messages since given tracking token.
|
Modifier and Type | Method and Description |
---|---|
void |
MongoSagaStore.insertSaga(Class<?> sagaType,
String sagaIdentifier,
Object saga,
TrackingToken token,
Set<AssociationValue> associationValues) |
void |
MongoSagaStore.updateSaga(Class<?> sagaType,
String sagaIdentifier,
Object saga,
TrackingToken token,
AssociationValues associationValues) |
Modifier and Type | Class and Description |
---|---|
class |
MongoTrackingToken
Tracking token implementation produced by the
MongoEventStorageEngine to keep track of the position in an
event stream. |
Modifier and Type | Method and Description |
---|---|
protected List<? extends TrackedEventData<?>> |
MongoEventStorageEngine.fetchTrackedEvents(TrackingToken lastToken,
int batchSize) |
List<? extends TrackedEventData<?>> |
StorageStrategy.findTrackedEvents(com.mongodb.client.MongoCollection<org.bson.Document> eventCollection,
TrackingToken lastToken,
int batchSize)
Returns a batch of tracked events with a tracking token above the given
lastToken . |
List<? extends TrackedEventData<?>> |
AbstractMongoEventStorageStrategy.findTrackedEvents(com.mongodb.client.MongoCollection<org.bson.Document> eventCollection,
TrackingToken lastToken,
int batchSize) |
Modifier and Type | Method and Description |
---|---|
TrackingToken |
MongoTokenStore.fetchToken(String processorName,
int segment)
|
Modifier and Type | Method and Description |
---|---|
void |
MongoTokenStore.storeToken(TrackingToken token,
String processorName,
int segment) |
Modifier and Type | Method and Description |
---|---|
Optional<TrackingToken> |
UpcastedEventRepresentation.getTrackingToken() |
Optional<TrackingToken> |
IntermediateEventRepresentation.getTrackingToken()
Returns the tracking token of the event, or an empty Optional if the message wrapping the object being upcast
does not contain a tracking token.
|
Optional<TrackingToken> |
InitialEventRepresentation.getTrackingToken() |
Copyright © 2010–2017. All rights reserved.