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