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 . |
StreamableMessageSource<TrackedEventMessage<?>> |
createStreamableMessageSourceForContext(String context)
Creates a
StreamableMessageSource that streams events from the given context , rather than the
default context the application was configured to connect to. |
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, storeSnapshot
afterCommit, commit, intercept, publish, queuedMessages, registerDispatchInterceptor, subscribe
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
publish, publish, registerDispatchInterceptor
subscribe
createTokenSince
protected 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.
AxonServerEventStore
public TrackingEventStream openStream(TrackingToken trackingToken)
StreamableMessageSource
trackingToken
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()
AbstractEventStore
EventStorageEngine
used by the event store.storageEngine
in class AbstractEventStore
public StreamableMessageSource<TrackedEventMessage<?>> createStreamableMessageSourceForContext(String context)
StreamableMessageSource
that streams events from the given context
, rather than the
default context the application was configured to connect to.context
- the name of the context to create a message source forStreamableMessageSource
of TrackedEventMessage
s tied to the given context
Copyright © 2010–2020. All rights reserved.