Package | Description |
---|---|
org.axonframework.commandhandling.disruptor | |
org.axonframework.domain |
The domain components of the Axon Framework, mainly the Aggregates and Events.
|
org.axonframework.eventsourcing |
Classes related to event sourcing.
|
org.axonframework.eventstore |
Definitions and implementations of the Event store, the mechanism that can load event streams and append events to
them.
|
org.axonframework.eventstore.fs |
Package containing classes necessary to implement a FileSystem based implementation of the EventStore
|
org.axonframework.eventstore.jdbc |
JDBC Implementation of the EventStore.
|
org.axonframework.eventstore.jpa |
JPA Implementation of the EventStore.
|
org.axonframework.eventstore.mongo | |
org.axonframework.gae.eventstore | |
org.axonframework.quickstart |
Modifier and Type | Method and Description |
---|---|
DomainEventStream |
DisruptorUnitOfWork.getEventsToStore()
Returns the events that need to be stored as part of this Unit of Work.
|
Modifier and Type | Class and Description |
---|---|
class |
SimpleDomainEventStream
Creates a DomainEventStream that streams the contents of a list.
|
Modifier and Type | Method and Description |
---|---|
static DomainEventStream |
SimpleDomainEventStream.emptyStream()
Creates an empty stream.
|
DomainEventStream |
EventContainer.getEventStream()
Read the events inside this container using a
DomainEventStream . |
DomainEventStream |
AggregateRoot.getUncommittedEvents()
Returns a DomainEventStream to the events in the aggregate that have been raised since creation or the last
commit.
|
DomainEventStream |
AbstractAggregateRoot.getUncommittedEvents()
Returns a DomainEventStream to the events in the aggregate that have been raised since creation or the last
commit.
|
Modifier and Type | Method and Description |
---|---|
DomainEventStream |
EventStreamDecorator.decorateForAppend(String aggregateType,
EventSourcedAggregateRoot aggregate,
DomainEventStream eventStream)
Called when an event stream is appended to the event store.
|
DomainEventStream |
EventCountSnapshotterTrigger.decorateForAppend(String aggregateType,
EventSourcedAggregateRoot aggregate,
DomainEventStream eventStream) |
DomainEventStream |
CompositeEventStreamDecorator.decorateForAppend(String aggregateType,
EventSourcedAggregateRoot aggregate,
DomainEventStream eventStream) |
DomainEventStream |
EventStreamDecorator.decorateForRead(String aggregateType,
Object aggregateIdentifier,
DomainEventStream eventStream)
Called when an event stream is read from the event store.
|
DomainEventStream |
EventCountSnapshotterTrigger.decorateForRead(String aggregateType,
Object aggregateIdentifier,
DomainEventStream eventStream) |
DomainEventStream |
CompositeEventStreamDecorator.decorateForRead(String aggregateType,
Object aggregateIdentifier,
DomainEventStream eventStream) |
Modifier and Type | Method and Description |
---|---|
protected DomainEventMessage |
AggregateSnapshotter.createSnapshot(String typeIdentifier,
Object aggregateIdentifier,
DomainEventStream eventStream) |
protected abstract DomainEventMessage |
AbstractSnapshotter.createSnapshot(String typeIdentifier,
Object aggregateIdentifier,
DomainEventStream eventStream)
Creates a snapshot event for an aggregate of the given
typeIdentifier of which passed events are
available in the given eventStream . |
DomainEventStream |
EventStreamDecorator.decorateForAppend(String aggregateType,
EventSourcedAggregateRoot aggregate,
DomainEventStream eventStream)
Called when an event stream is appended to the event store.
|
DomainEventStream |
EventCountSnapshotterTrigger.decorateForAppend(String aggregateType,
EventSourcedAggregateRoot aggregate,
DomainEventStream eventStream) |
DomainEventStream |
CompositeEventStreamDecorator.decorateForAppend(String aggregateType,
EventSourcedAggregateRoot aggregate,
DomainEventStream eventStream) |
DomainEventStream |
EventStreamDecorator.decorateForRead(String aggregateType,
Object aggregateIdentifier,
DomainEventStream eventStream)
Called when an event stream is read from the event store.
|
DomainEventStream |
EventCountSnapshotterTrigger.decorateForRead(String aggregateType,
Object aggregateIdentifier,
DomainEventStream eventStream) |
DomainEventStream |
CompositeEventStreamDecorator.decorateForRead(String aggregateType,
Object aggregateIdentifier,
DomainEventStream eventStream) |
void |
EventSourcedAggregateRoot.initializeState(DomainEventStream domainEventStream)
Initialize the state of this aggregate using the events in the provided
DomainEventStream . |
void |
AbstractEventSourcedAggregateRoot.initializeState(DomainEventStream domainEventStream)
Initialize the state of this aggregate using the events in the provided
DomainEventStream . |
protected void |
EventSourcingRepository.resolveConflicts(T aggregate,
DomainEventStream unseenEvents)
Resolve (potential) conflicts for the given
aggregate , where given unseenEvents may
have been concurrently applied. |
Modifier and Type | Method and Description |
---|---|
DomainEventStream |
EventStore.readEvents(String type,
Object identifier)
Read the events of the aggregate identified by the given type and identifier that allow the current aggregate
state to be rebuilt.
|
DomainEventStream |
PartialStreamSupport.readEvents(String type,
Object identifier,
long firstSequenceNumber)
Returns a Stream containing events for the aggregate identified by the given
type and identifier , starting at the event with the given firstSequenceNumber (included). |
DomainEventStream |
PartialStreamSupport.readEvents(String type,
Object identifier,
long firstSequenceNumber,
long lastSequenceNumber)
Returns a Stream containing events for the aggregate identified by the given
type and identifier , starting at the event with the given firstSequenceNumber (included) up to and including the
event with given lastSequenceNumber . |
Modifier and Type | Method and Description |
---|---|
void |
EventStore.appendEvents(String type,
DomainEventStream events)
Append the events in the given
stream to the event store. |
Modifier and Type | Class and Description |
---|---|
class |
FileSystemBufferedReaderDomainEventStream
DomainEventStream implementation that reads DomainEvents from the filesystem using an
InputStream . |
Modifier and Type | Method and Description |
---|---|
DomainEventStream |
FileSystemEventStore.readEvents(String type,
Object aggregateIdentifier) |
Modifier and Type | Method and Description |
---|---|
void |
FileSystemEventStore.appendEvents(String type,
DomainEventStream eventsToStore)
Append the events in the given
stream to the event store. |
Modifier and Type | Method and Description |
---|---|
DomainEventStream |
JdbcEventStore.readEvents(String type,
Object identifier)
Read the events of the aggregate identified by the given type and identifier that allow the current aggregate
state to be rebuilt.
|
DomainEventStream |
JdbcEventStore.readEvents(String type,
Object identifier,
long firstSequenceNumber) |
DomainEventStream |
JdbcEventStore.readEvents(String type,
Object identifier,
long firstSequenceNumber,
long lastSequenceNumber) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcEventStore.appendEvents(String type,
DomainEventStream events)
Append the events in the given
stream to the event store. |
Modifier and Type | Method and Description |
---|---|
DomainEventStream |
JpaEventStore.readEvents(String type,
Object identifier)
Read the events of the aggregate identified by the given type and identifier that allow the current aggregate
state to be rebuilt.
|
DomainEventStream |
JpaEventStore.readEvents(String type,
Object identifier,
long firstSequenceNumber) |
DomainEventStream |
JpaEventStore.readEvents(String type,
Object identifier,
long firstSequenceNumber,
long lastSequenceNumber) |
Modifier and Type | Method and Description |
---|---|
void |
JpaEventStore.appendEvents(String type,
DomainEventStream events)
Append the events in the given
stream to the event store. |
Modifier and Type | Method and Description |
---|---|
DomainEventStream |
MongoEventStore.readEvents(String type,
Object identifier) |
DomainEventStream |
MongoEventStore.readEvents(String type,
Object identifier,
long firstSequenceNumber) |
DomainEventStream |
MongoEventStore.readEvents(String type,
Object identifier,
long firstSequenceNumber,
long lastSequenceNumber) |
Modifier and Type | Method and Description |
---|---|
void |
MongoEventStore.appendEvents(String type,
DomainEventStream events) |
Modifier and Type | Method and Description |
---|---|
DomainEventStream |
GaeEventStore.readEvents(String type,
Object identifier) |
Modifier and Type | Method and Description |
---|---|
void |
GaeEventStore.appendEvents(String type,
DomainEventStream events) |
Modifier and Type | Method and Description |
---|---|
DomainEventStream |
RunEventReplay.StubEventStore.readEvents(String type,
Object identifier) |
Modifier and Type | Method and Description |
---|---|
void |
RunEventReplay.StubEventStore.appendEvents(String type,
DomainEventStream events) |
Copyright © 2010-2014. All Rights Reserved.