org.axonframework.axonserver.connector.event.axon

Class AxonServerEventStore

java.lang.Object

org.axonframework.eventhandling.AbstractEventBus

org.axonframework.eventsourcing.eventstore.AbstractEventStore

org.axonframework.axonserver.connector.event.axon.AxonServerEventStore

All Implemented Interfaces:

DomainEventSequenceAware, EventBus, EventStore, MessageDispatchInterceptorSupport<EventMessage<?>>, StreamableMessageSource<TrackedEventMessage<?>>, SubscribableMessageSource<EventMessage<?>>

public class AxonServerEventStore
extends AbstractEventStore

Axon EventStore implementation that connects to the AxonIQ AxonServer Server to store and retrieve Events.

Since:

4.0

Author:

Zoltan Altfatter, Marc Gathier, Allard Buijze

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AxonServerEventStore.Builder Builder class to instantiate a AxonServerEventStore.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AxonServerEventStore(AxonServerEventStore.Builder builder) Instantiate a AxonServerEventStore based on the fields contained in the AxonServerEventStore.Builder.

Method Summary

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.

Methods inherited from class org.axonframework.eventsourcing.eventstore.AbstractEventStore

createHeadToken, createTailToken, createTokenAt, handleSnapshotReadingError, lastSequenceNumberFor, prepareCommit, readEvents, readEvents, stagedDomainEventMessages, storeSnapshot

Methods inherited from class org.axonframework.eventhandling.AbstractEventBus

afterCommit, commit, intercept, publish, queuedMessages, registerDispatchInterceptor, subscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.axonframework.eventhandling.EventBus

publish, publish, registerDispatchInterceptor

Methods inherited from interface org.axonframework.messaging.SubscribableMessageSource

subscribe

Methods inherited from interface org.axonframework.messaging.StreamableMessageSource

createTokenSince

Constructor Detail

AxonServerEventStore

protected AxonServerEventStore(AxonServerEventStore.Builder builder)

Instantiate a 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.

Parameters:

builder - the AxonServerEventStore.Builder used to instantiate a AxonServerEventStore instance

Method Detail

builder

public static AxonServerEventStore.Builder builder()

Instantiate a Builder to be able to create a 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.

Returns:

a Builder to be able to create a AxonServerEventStore

openStream

public TrackingEventStream openStream(TrackingToken trackingToken)

Description copied from interface: StreamableMessageSource

Open a stream containing all messages since given tracking token. Pass a 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.

Parameters:

trackingToken - object containing the position in the stream or null to open a stream containing all messages

Returns:

a stream of messages since the given trackingToken

query

public QueryResultStream query(String query,
                               boolean liveUpdates)

storageEngine

protected org.axonframework.axonserver.connector.event.axon.AxonServerEventStore.AxonIQEventStorageEngine storageEngine()

Description copied from class: AbstractEventStore

Returns the EventStorageEngine used by the event store.

Overrides:

storageEngine in class AbstractEventStore

Returns:

The event storage engine used by this event store

createStreamableMessageSourceForContext

public 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.

Parameters:

context - the name of the context to create a message source for

Returns:

a StreamableMessageSource of TrackedEventMessages tied to the given context