default AggregateEventStream |
EventChannel.loadSnapshot(String aggregateIdentifier) |
Loads the Snapshot Event for the given aggregateIdentifier with the highest sequence number.
|
default AggregateEventStream |
EventChannel.loadSnapshots(String aggregateIdentifier,
long maxSequence,
int maxResults) |
Loads Snapshot Events for the given aggregateIdentifier with sequence number lower or equal to
maxSequence, returning at most maxResults number of snapshots.
|
AggregateEventStream |
EventChannel.loadSnapshots(String aggregateIdentifier,
long initialSequence,
long maxSequence,
int maxResults) |
Loads Snapshot Events for the given aggregateIdentifier with sequence number between
initialSequence and maxSequence (inclusive), returning at most maxResults number of snapshots.
|
default AggregateEventStream |
EventChannel.openAggregateStream(String aggregateIdentifier) |
Opens a stream for consuming Events from a single aggregate, allowing the first event to be a Snapshot Event.
|
AggregateEventStream |
EventChannel.openAggregateStream(String aggregateIdentifier,
boolean allowSnapshots) |
Opens a stream for consuming Events from a single aggregate, with given allowSnapshots indicating whether
the first Event may be a Snapshot Event.
|
default AggregateEventStream |
EventChannel.openAggregateStream(String aggregateIdentifier,
long initialSequence) |
Opens a stream for consuming Events from a single aggregate, starting with the given initialSequence.
|
AggregateEventStream |
EventChannel.openAggregateStream(String aggregateIdentifier,
long initialSequence,
long maxSequence) |
Opens a stream for consuming Events from a single aggregate, starting with the given initialSequence
until the given maxSequence.
|