org.axonframework.eventsourcing.eventstore

Class AbstractEventStore

java.lang.Object

org.axonframework.eventhandling.AbstractEventBus

org.axonframework.eventsourcing.eventstore.AbstractEventStore

All Implemented Interfaces:

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

Direct Known Subclasses:

EmbeddedEventStore

public abstract class AbstractEventStore
extends AbstractEventBus
implements EventStore

Abstract implementation of an EventStore that uses a EventStorageEngine to store and load events.

Author:

Rene de Waele

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractEventStore(EventStorageEngine storageEngine) Initializes an event store with given storageEngine and NoOpMessageMonitor.
protected	AbstractEventStore(EventStorageEngine storageEngine, MessageMonitor<? super EventMessage<?>> messageMonitor) Initializes an event store with given storageEngine and messageMonitor.

Method Summary

Modifier and Type	Method and Description
protected void	prepareCommit(List<? extends EventMessage<?>> events) Process given events while the Unit of Work root is preparing for commit.
DomainEventStream	readEvents(String aggregateIdentifier) Open an event stream containing all domain events belonging to the given aggregateIdentifier.
DomainEventStream	readEvents(String aggregateIdentifier, long firstSequenceNumber) Open an event stream containing all domain events belonging to the given aggregateIdentifier.
protected Stream<? extends DomainEventMessage<?>>	stagedDomainEventMessages(String aggregateIdentifier) Returns a Stream of all DomainEventMessages that have been staged for publication by an Aggregate with given aggregateIdentifier.
protected EventStorageEngine	storageEngine() Returns the EventStorageEngine used by the event store.
void	storeSnapshot(DomainEventMessage<?> snapshot) Stores the given (temporary) snapshot event.

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

openStream, publish, publish, registerDispatchInterceptor

Methods inherited from interface org.axonframework.messaging.SubscribableMessageSource

subscribe

Constructor Detail

AbstractEventStore

protected AbstractEventStore(EventStorageEngine storageEngine)

Initializes an event store with given storageEngine and NoOpMessageMonitor.

Parameters:

storageEngine - The storage engine used to store and load events

AbstractEventStore

protected AbstractEventStore(EventStorageEngine storageEngine,
                             MessageMonitor<? super EventMessage<?>> messageMonitor)

Initializes an event store with given storageEngine and messageMonitor.

Parameters:

storageEngine - The storage engine used to store and load events

messageMonitor - The monitor used to record event publications

Method Detail

prepareCommit

protected void prepareCommit(List<? extends EventMessage<?>> events)

Description copied from class: AbstractEventBus

Process given events while the Unit of Work root is preparing for commit. The default implementation signals the registered MessageMonitor that the given events are ingested and passes the events to each registered event processor.

Overrides:

prepareCommit in class AbstractEventBus

Parameters:

events - Events to be published by this Event Bus

readEvents

public DomainEventStream readEvents(String aggregateIdentifier)

Open an event stream containing all domain events belonging to the given 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.

Specified by:

readEvents in interface EventStore

Parameters:

aggregateIdentifier - the identifier of the aggregate whose events to fetch

Returns:

a stream of all currently stored events of the aggregate

stagedDomainEventMessages

protected Stream<? extends DomainEventMessage<?>> stagedDomainEventMessages(String aggregateIdentifier)

Returns a Stream of all DomainEventMessages that have been staged for publication by an Aggregate with given aggregateIdentifier.

Parameters:

aggregateIdentifier - The identifier of the aggregate to get staged events for

Returns:

a Stream of DomainEventMessage of the identified aggregate

readEvents

public DomainEventStream readEvents(String aggregateIdentifier,
                                    long firstSequenceNumber)

Description copied from interface: EventStore

Open an event stream containing all domain events belonging to the given 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.

The default implementation invokes EventStore.readEvents(String) and then filters out events with a sequence number smaller than firstSequenceNumber.

Specified by:

readEvents in interface EventStore

Parameters:

aggregateIdentifier - the identifier of the aggregate whose events to fetch

firstSequenceNumber - the expected sequence number of the first event in the returned stream

Returns:

a stream of all currently stored events of the aggregate

storeSnapshot

public void storeSnapshot(DomainEventMessage<?> snapshot)

Description copied from interface: EventStore

Stores the given (temporary) snapshot event. This snapshot replaces the segment of the event stream identified by the snapshot's Aggregate Identifier up to (and including) the event with the snapshot's sequence number.

These snapshots will only affect the DomainEventStream returned by the EventStore.readEvents(String) method. They do not change the events returned by EventBus.openStream(TrackingToken) or those received by using SubscribableMessageSource.subscribe(java.util.function.Consumer).

Note that snapshots are considered a temporary replacement for Events, and are used as performance optimization. Event Store implementations may choose to ignore or delete snapshots.

Specified by:

storeSnapshot in interface EventStore

Parameters:

snapshot - The snapshot to replace part of the DomainEventStream.

storageEngine

protected EventStorageEngine storageEngine()

Returns the EventStorageEngine used by the event store.

Returns:

The event storage engine used by this event store