Package | Description |
---|---|
org.axonframework.eventsourcing |
Classes related to event sourcing.
|
org.axonframework.eventsourcing.eventstore |
Definitions and implementations of the Event store, the mechanism that can load event streams and append events to
them.
|
org.axonframework.eventsourcing.eventstore.inmemory |
Modifier and Type | Method and Description |
---|---|
DomainEventStream |
FilteringEventStorageEngine.readEvents(String aggregateIdentifier) |
protected DomainEventStream |
EventSourcingRepository.readEvents(String aggregateIdentifier)
Reads the events for the given aggregateIdentifier from the eventStore.
|
DomainEventStream |
FilteringEventStorageEngine.readEvents(String aggregateIdentifier,
long firstSequenceNumber) |
static DomainEventStream |
EventStreamUtils.upcastAndDeserializeDomainEvents(Stream<? extends DomainEventData<?>> eventEntryStream,
Serializer serializer,
EventUpcaster upcasterChain)
Upcasts and deserializes the given
eventEntryStream using the given serializer and
upcasterChain . |
Modifier and Type | Method and Description |
---|---|
static Stream<? extends DomainEventMessage<?>> |
EventStreamUtils.asStream(DomainEventStream domainEventStream)
Convert the given
domainEventStream to a regular java Stream of domain event messages. |
protected DomainEventMessage |
AggregateSnapshotter.createSnapshot(Class<?> aggregateType,
String aggregateIdentifier,
DomainEventStream eventStream) |
protected abstract DomainEventMessage |
AbstractSnapshotter.createSnapshot(Class<?> aggregateType,
String aggregateIdentifier,
DomainEventStream eventStream)
Creates a snapshot event for an aggregate of which passed events are available in the given
eventStream . |
void |
EventSourcedAggregate.initializeState(DomainEventStream eventStream)
Initialize the state of this Event Sourced Aggregate with the events from the given
eventStream . |
Modifier and Type | Class and Description |
---|---|
class |
ConcatenatingDomainEventStream
DomainEventStream implementation that concatenates multiple streams, taking into account that some sequence
numbers may appear in more than one stream.
|
class |
FilteringDomainEventStream
DomainEventStream implementation that filters a stream.
|
class |
IteratorBackedDomainEventStream
DomainEventStream implementation that gets its messages from an Iterator.
|
Modifier and Type | Method and Description |
---|---|
static DomainEventStream |
DomainEventStream.concat(DomainEventStream a,
DomainEventStream b)
Concatenate two DomainEventStreams.
|
static DomainEventStream |
DomainEventStream.empty()
Create an empty DomainEventStream.
|
default DomainEventStream |
DomainEventStream.filter(Predicate<? super DomainEventMessage<?>> filter)
Returns a stream that provides the items of this stream that match the given
filter . |
static DomainEventStream |
DomainEventStream.of(DomainEventMessage<?>... events)
Create a new DomainEventStream from the given
events . |
static DomainEventStream |
DomainEventStream.of(DomainEventMessage<?> event)
Create a new DomainEventStream containing only the given
event . |
static DomainEventStream |
DomainEventStream.of(List<? extends DomainEventMessage<?>> list)
Create a new DomainEventStream with events obtained from the given
list . |
static DomainEventStream |
DomainEventStream.of(Stream<? extends DomainEventMessage<?>> stream)
Create a new DomainEventStream with events obtained from the given
stream . |
static DomainEventStream |
DomainEventStream.of(Stream<? extends DomainEventMessage<?>> stream,
Supplier<Long> sequenceNumberSupplier)
Create a new DomainEventStream with events obtained from the given
stream . |
DomainEventStream |
EventStore.readEvents(String aggregateIdentifier)
Open an event stream containing all domain events belonging to the given
aggregateIdentifier . |
default DomainEventStream |
EventStorageEngine.readEvents(String aggregateIdentifier)
Get a
DomainEventStream containing all events published by the aggregate with given aggregateIdentifier . |
DomainEventStream |
AbstractEventStore.readEvents(String aggregateIdentifier)
Open an event stream containing all domain events belonging to the given
aggregateIdentifier . |
DomainEventStream |
AbstractEventStorageEngine.readEvents(String aggregateIdentifier,
long firstSequenceNumber) |
DomainEventStream |
SequenceEventStorageEngine.readEvents(String aggregateIdentifier,
long firstSequenceNumber) |
default DomainEventStream |
EventStore.readEvents(String aggregateIdentifier,
long firstSequenceNumber)
Open an event stream containing all domain events belonging to the given
aggregateIdentifier . |
DomainEventStream |
EventStorageEngine.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 . |
DomainEventStream |
AbstractEventStore.readEvents(String aggregateIdentifier,
long firstSequenceNumber) |
Modifier and Type | Method and Description |
---|---|
static DomainEventStream |
DomainEventStream.concat(DomainEventStream a,
DomainEventStream b)
Concatenate two DomainEventStreams.
|
Constructor and Description |
---|
ConcatenatingDomainEventStream(DomainEventStream... streams)
Initialize the stream, concatenating the given
streams . |
FilteringDomainEventStream(DomainEventStream delegate,
Predicate<? super DomainEventMessage<?>> filter)
Initialize the stream, filter the given
stream with the given
filter . |
Constructor and Description |
---|
ConcatenatingDomainEventStream(Collection<DomainEventStream> streams)
Initialize the stream, concatenating the given
streams . |
Modifier and Type | Method and Description |
---|---|
DomainEventStream |
InMemoryEventStorageEngine.readEvents(String aggregateIdentifier,
long firstSequenceNumber) |
Copyright © 2010–2018. All rights reserved.