public class AxonServerEventStore extends AbstractEventStore
|Modifier and Type||Class and Description|
Builder class to instantiate a
|Modifier||Constructor and Description|
|Modifier and Type||Method and Description|
Instantiate a Builder to be able to create a
Open a stream containing all messages since given tracking token.
Open an event stream containing all domain events belonging to the given
createHeadToken, createTailToken, createTokenAt, lastSequenceNumberFor, prepareCommit, readEvents, stagedDomainEventMessages, storeSnapshot
afterCommit, commit, intercept, publish, queuedMessages, registerDispatchInterceptor, subscribe
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
protected AxonServerEventStore(AxonServerEventStore.Builder builder)
AxonServerEventStorebased on the fields contained in the
Will assert that the
EventStorageEngine is set. If not, the
AxonServerConnectionManager should minimally be provided to create an AxonServer specific EventStorageEngine
implementation. If either of these
null assertions fail, an
AxonConfigurationException will be
public static AxonServerEventStore.Builder builder()
The main goal of this Builder is to instantiate an AxonServer specific
EventStorageEngine. The properties
which may be provided through this Builder are thus all used to end up with that EventStorageEngine
implementation. An EventStorageEngine may be provided directly however, although we encourage the usage of the
AxonServerEventStore.Builder.axonServerConnectionManager functions to let it be created.
public TrackingEventStream openStream(TrackingToken trackingToken)
nullto open a stream containing all available messages. Note that the returned stream is infinite, so beware of applying terminal operations to the returned stream.
trackingToken- object containing the position in the stream or
nullto open a stream containing all messages
protected org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.AxonIQEventStorageEngine storageEngine()
EventStorageEngineused by the event store.
public StreamableMessageSource<TrackedEventMessage<?>> createStreamableMessageSourceForContext(String context)
StreamableMessageSourcethat streams events from the given
context, rather than the default context the application was configured to connect to.
protected Optional<DomainEventMessage<?>> handleSnapshotReadingError(String aggregateIdentifier, Throwable e)
LinkageError) occurs while attempting to read a snapshot event. This method can be overridden to change the default behavior, which is to log the exception (warn level) and ignore the snapshot.
Overriding implementations may choose to return normally, or raise an exception. Exceptions raised from this
method are propagated to the caller of the
Returning an empty Optional will force the initialization of the aggregate to happen based on the entire event stream of that aggregate.
aggregateIdentifier- The identifier of the aggregate for which an snapshot failed to load
e- The exception or error that occurred while loading or deserializing the snapshot
public DomainEventStream readEvents(String aggregateIdentifier)
The returned stream is finite, ending with the last known event of the aggregate. If the event store holds no events of the given aggregate an empty stream is returned.
This implementation returns a
DomainEventStream starting with the last stored snapshot of the aggregate
followed by subsequent domain events.
Copyright © 2010–2023. All rights reserved.