org.axonframework.eventsourcing.eventstore

Interface EventStore

All Superinterfaces:

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

All Known Implementing Classes:

AbstractEventStore, EmbeddedEventStore

public interface EventStore
extends EventBus

Provides a mechanism to open streams from events in the the underlying event storage.

The EventStore provides access to both the global event stream comprised of all domain and application events, as well as streams containing only events of a single aggregate.

Author:

Allard Buijze, Rene de Waele

Method Summary

Modifier and Type	Method and Description
DomainEventStream	readEvents(String aggregateIdentifier) Open an event stream containing all domain events belonging to the given aggregateIdentifier.
default DomainEventStream	readEvents(String aggregateIdentifier, long firstSequenceNumber) Open an event stream containing all domain events belonging to the given aggregateIdentifier.
void	storeSnapshot(DomainEventMessage<?> snapshot) Stores the given (temporary) snapshot event.

Methods inherited from interface org.axonframework.eventhandling.EventBus

openStream, publish, publish, registerDispatchInterceptor

Methods inherited from interface org.axonframework.messaging.SubscribableMessageSource

subscribe

Method Detail

readEvents

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.

Parameters:

aggregateIdentifier - the identifier of the aggregate whose events to fetch

Returns:

a stream of all currently stored events of the aggregate

readEvents

default DomainEventStream readEvents(String aggregateIdentifier,
                                     long firstSequenceNumber)

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 readEvents(String) and then filters out events with a sequence number smaller than firstSequenceNumber.

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

void storeSnapshot(DomainEventMessage<?> snapshot)

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

Parameters:

snapshot - The snapshot to replace part of the DomainEventStream.