public class AxonServerEventStore extends AbstractEventStore
| Modifier and Type | Class and Description |
|---|---|
static class |
AxonServerEventStore.Builder
Builder class to instantiate a
AxonServerEventStore. |
| Modifier | Constructor and Description |
|---|---|
protected |
AxonServerEventStore(AxonServerEventStore.Builder builder)
Instantiate a
AxonServerEventStore based on the fields contained in the AxonServerEventStore.Builder. |
| Modifier and Type | Method and Description |
|---|---|
static AxonServerEventStore.Builder |
builder()
Instantiate a Builder to be able to create a
AxonServerEventStore. |
TrackingEventStream |
openStream(TrackingToken trackingToken)
Open a stream containing all messages since given tracking token.
|
QueryResultStream |
query(String query,
boolean liveUpdates) |
protected org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.AxonIQEventStorageEngine |
storageEngine()
Returns the
EventStorageEngine used by the event store. |
createHeadToken, createTailToken, createTokenAt, handleSnapshotReadingError, lastSequenceNumberFor, prepareCommit, readEvents, readEvents, stagedDomainEventMessages, storeSnapshotafterCommit, commit, intercept, publish, queuedMessages, registerDispatchInterceptor, subscribeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublish, publish, registerDispatchInterceptorsubscribecreateTokenSinceprotected AxonServerEventStore(AxonServerEventStore.Builder builder)
AxonServerEventStore based on the fields contained in the AxonServerEventStore.Builder.
Will assert that the EventStorageEngine is set. If not, the AxonServerConfiguration and
AxonServerConnectionManager should minimally be provided to create an AxonServer specific
EventStorageEngine implementation. If either of these null assertions fail, an
AxonConfigurationException will be thrown.
builder - the AxonServerEventStore.Builder used to instantiate a AxonServerEventStore instancepublic static AxonServerEventStore.Builder builder()
AxonServerEventStore.
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.configuration and AxonServerEventStore.Builder.axonServerConnectionManager functions to let it be created.
The snapshot Serializer is defaulted to a XStreamSerializer, the event Serializer also defaults
to a XStreamSerializer and the EventUpcaster defaults to a NoOpEventUpcaster.
The AxonServerConfiguration and AxonServerConnectionManager are hard requirements if no
EventStorageEngine is provided directly.
AxonServerEventStorepublic TrackingEventStream openStream(TrackingToken trackingToken)
StreamableMessageSourcetrackingToken of null to
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 null to open a stream containing all
messagespublic QueryResultStream query(String query, boolean liveUpdates)
protected org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.AxonIQEventStorageEngine storageEngine()
AbstractEventStoreEventStorageEngine used by the event store.storageEngine in class AbstractEventStoreCopyright © 2010–2019. All rights reserved.