public class FilteringEventStorageEngine extends Object implements EventStorageEngine
Constructor and Description |
---|
FilteringEventStorageEngine(EventStorageEngine delegate,
Predicate<? super EventMessage<?>> filter)
Initializes the FilteringEventStorageEngine delegating all event messages matching the given
filter to
the given delegate . |
Modifier and Type | Method and Description |
---|---|
void |
appendEvents(EventMessage<?>... events)
Append one or more events to the event storage.
|
void |
appendEvents(List<? extends EventMessage<?>> events)
Append a list of events to the event storage.
|
DomainEventStream |
readEvents(String aggregateIdentifier)
Get a
DomainEventStream containing all events published by the aggregate with given aggregateIdentifier . |
DomainEventStream |
readEvents(String aggregateIdentifier,
long firstSequenceNumber)
Get a
DomainEventStream containing all events published by the aggregate with given aggregateIdentifier starting with the first event having a sequence number that is equal or larger than the
given firstSequenceNumber . |
Stream<? extends TrackedEventMessage<?>> |
readEvents(TrackingToken trackingToken,
boolean mayBlock)
Open an event stream containing all events stored since given tracking token.
|
Optional<DomainEventMessage<?>> |
readSnapshot(String aggregateIdentifier)
Try to load a snapshot event of the aggregate with given
aggregateIdentifier . |
void |
storeSnapshot(DomainEventMessage<?> snapshot)
Store an event that contains a snapshot of an aggregate.
|
public FilteringEventStorageEngine(EventStorageEngine delegate, Predicate<? super EventMessage<?>> filter)
filter
to
the given delegate
.
Note that this only affects events stored in the StorageEngine. The EventStore
will still publish these
events to Subscribed event handlers. Tracking Event Processors take their events from the stored events, and
will therefore not receive any events blocked by this instance.
delegate
- the EventStorageEngine to store matching messages infilter
- the predicate that event messages must match against to be storedpublic void appendEvents(EventMessage<?>... events)
EventStorageEngine
Note that all events should have a unique event identifier. When storing domain events
events should also have a unique combination of aggregate id and sequence number.
By default this method creates a list of the offered events and then invokes EventStorageEngine.appendEvents(List)
.
appendEvents
in interface EventStorageEngine
events
- Events to append to the event storagepublic void appendEvents(List<? extends EventMessage<?>> events)
EventStorageEngine
Note that all events should have a unique event identifier. When storing domain events
events should also have a unique combination of aggregate id and sequence number.
appendEvents
in interface EventStorageEngine
events
- Events to append to the event storagepublic void storeSnapshot(DomainEventMessage<?> snapshot)
EventStorageEngine
storeSnapshot
in interface EventStorageEngine
snapshot
- The snapshot event of the aggregate that is to be storedpublic Stream<? extends TrackedEventMessage<?>> readEvents(TrackingToken trackingToken, boolean mayBlock)
EventStorageEngine
trackingToken
of null
to open
a stream containing all available events.
If the value of the given mayBlock
is true
the returned stream is allowed to block while waiting
for new event messages if the end of the stream is reached.
readEvents
in interface EventStorageEngine
trackingToken
- Object describing the global index of the last processed event or null
to create a
stream of all events in the storemayBlock
- If true
the storage engine may optionally choose to block to wait for new event
messages if the end of the stream is reached.public DomainEventStream readEvents(String aggregateIdentifier)
EventStorageEngine
DomainEventStream
containing all events published by the aggregate with given aggregateIdentifier
. By default calling this method is shorthand for an invocation of
EventStorageEngine.readEvents(String, long)
with a sequence number of 0.
The returned stream is finite, i.e. it should not block to wait for further events if the end of the event stream of the aggregate is reached.
readEvents
in interface EventStorageEngine
aggregateIdentifier
- The identifier of the aggregate to return an event stream forpublic DomainEventStream readEvents(String aggregateIdentifier, long firstSequenceNumber)
EventStorageEngine
DomainEventStream
containing all events published by the aggregate with given aggregateIdentifier
starting with the first event having a sequence number that is equal or larger than the
given firstSequenceNumber
.
The returned stream is finite, i.e. it should not block to wait for further events if the end of the event stream of the aggregate is reached.
readEvents
in interface EventStorageEngine
aggregateIdentifier
- The identifier of the aggregatefirstSequenceNumber
- The expected sequence number of the first event in the returned streampublic Optional<DomainEventMessage<?>> readSnapshot(String aggregateIdentifier)
EventStorageEngine
aggregateIdentifier
. If the storage engine has
no snapshot event of the aggregate, an empty Optional is returned.readSnapshot
in interface EventStorageEngine
aggregateIdentifier
- The identifier of the aggregateCopyright © 2010–2017. All rights reserved.