Package | Description |
---|---|
org.axonframework.commandhandling.disruptor | |
org.axonframework.domain |
The domain components of the Axon Framework, mainly the Aggregates and Events.
|
org.axonframework.eventhandling.replay | |
org.axonframework.eventsourcing |
Classes related to event sourcing.
|
org.axonframework.eventsourcing.annotation | |
org.axonframework.eventsourcing.conflictresolvers | |
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.jpa |
JPA Implementation of the EventStore.
|
org.axonframework.eventstore.mongo | |
org.axonframework.gae.eventstore | |
org.axonframework.quickstart.handler | |
org.axonframework.serializer | |
org.axonframework.test |
Classes in support of testing Axon based applications.
|
Modifier and Type | Method and Description |
---|---|
<T> DomainEventMessage<T> |
DisruptorUnitOfWork.onRegisteredEvent(DomainEventMessage<T> event) |
Modifier and Type | Method and Description |
---|---|
<T> DomainEventMessage<T> |
DisruptorUnitOfWork.onRegisteredEvent(DomainEventMessage<T> event) |
Modifier and Type | Class and Description |
---|---|
class |
GenericDomainEventMessage<T>
Generic implementation of the DomainEventMessage interface.
|
Modifier and Type | Method and Description |
---|---|
<T> DomainEventMessage<T> |
EventContainer.addEvent(MetaData metaData,
T payload)
Add an event to this container.
|
DomainEventMessage<T> |
DomainEventMessage.andMetaData(Map<String,?> metaData)
Returns a copy of this DomainEventMessage with its MetaData merged with the given
metaData . |
DomainEventMessage |
SimpleDomainEventStream.next()
Returns the next events in the stream, if available.
|
DomainEventMessage |
DomainEventStream.next()
Returns the next events in the stream, if available.
|
<T> DomainEventMessage<T> |
EventRegistrationCallback.onRegisteredEvent(DomainEventMessage<T> event)
Invoked when an Aggregate registers an Event for publication.
|
DomainEventMessage |
SimpleDomainEventStream.peek()
Returns the next events in the stream, if available, without moving the pointer forward.
|
DomainEventMessage |
DomainEventStream.peek()
Returns the next events in the stream, if available, without moving the pointer forward.
|
protected <T> DomainEventMessage<T> |
AbstractAggregateRoot.registerEvent(MetaData metaData,
T payload)
Registers an event to be published when the aggregate is saved.
|
protected <T> DomainEventMessage<T> |
AbstractAggregateRoot.registerEvent(T payload)
Registers an event to be published when the aggregate is saved, containing the given
payload and no
(additional) meta-data. |
DomainEventMessage<T> |
DomainEventMessage.withMetaData(Map<String,?> metaData)
Returns a copy of this DomainEventMessage with the given
metaData . |
Modifier and Type | Method and Description |
---|---|
List<DomainEventMessage> |
EventContainer.getEventList()
Returns an unmodifiable version of the backing list of events.
|
Modifier and Type | Method and Description |
---|---|
<T> DomainEventMessage<T> |
EventRegistrationCallback.onRegisteredEvent(DomainEventMessage<T> event)
Invoked when an Aggregate registers an Event for publication.
|
Constructor and Description |
---|
SimpleDomainEventStream(DomainEventMessage... events)
Initialize the event stream using the given
DomainEventMessage s and aggregate identifier. |
Constructor and Description |
---|
SimpleDomainEventStream(Collection<? extends DomainEventMessage> events)
Initialize the event stream using the given List of DomainEvent and aggregate identifier.
|
Modifier and Type | Method and Description |
---|---|
void |
IncomingMessageHandler.releaseMessage(DomainEventMessage message)
Invoked when a message has been replayed from the event store.
|
void |
DiscardingIncomingMessageHandler.releaseMessage(DomainEventMessage message) |
void |
BackloggingIncomingMessageHandler.releaseMessage(DomainEventMessage message) |
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 . |
Modifier and Type | Method and Description |
---|---|
T |
AggregateFactory.createAggregate(Object aggregateIdentifier,
DomainEventMessage<?> firstEvent)
Instantiate the aggregate using the given aggregate identifier and first event.
|
T |
AbstractAggregateFactory.createAggregate(Object aggregateIdentifier,
DomainEventMessage<?> firstEvent) |
T |
SpringPrototypeAggregateFactory.doCreateAggregate(Object aggregateIdentifier,
DomainEventMessage firstEvent) |
protected T |
GenericAggregateFactory.doCreateAggregate(Object aggregateIdentifier,
DomainEventMessage firstEvent)
Create an uninitialized Aggregate instance with the given
aggregateIdentifier . |
protected abstract T |
AbstractAggregateFactory.doCreateAggregate(Object aggregateIdentifier,
DomainEventMessage firstEvent)
Create an uninitialized Aggregate instance with the given
aggregateIdentifier . |
protected abstract void |
AbstractEventSourcedEntity.handle(DomainEventMessage event)
Apply state changes based on the given event.
|
protected abstract void |
AbstractEventSourcedAggregateRoot.handle(DomainEventMessage event)
Apply state changes based on the given event.
|
void |
EventSourcedEntity.handleRecursively(DomainEventMessage event)
Report the given
event for handling in the current instance (this ), as well as all the
entities referenced by this instance. |
void |
AbstractEventSourcedEntity.handleRecursively(DomainEventMessage event) |
Modifier and Type | Method and Description |
---|---|
void |
ConflictResolver.resolveConflicts(List<DomainEventMessage> appliedChanges,
List<DomainEventMessage> committedChanges)
Checks the given list of
appliedChanges and committedChanges for any conflicting
changes. |
void |
ConflictResolver.resolveConflicts(List<DomainEventMessage> appliedChanges,
List<DomainEventMessage> committedChanges)
Checks the given list of
appliedChanges and committedChanges for any conflicting
changes. |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractAnnotatedEntity.handle(DomainEventMessage event)
Calls the appropriate
EventHandler annotated handler with the
provided event. |
protected void |
AbstractAnnotatedAggregateRoot.handle(DomainEventMessage event)
Calls the appropriate
EventHandler annotated handler with the
provided event. |
Modifier and Type | Method and Description |
---|---|
void |
AcceptAllConflictResolver.resolveConflicts(List<DomainEventMessage> appliedChanges,
List<DomainEventMessage> committedChanges)
Checks the given list of
appliedChanges and committedChanges for any conflicting
changes. |
void |
AcceptAllConflictResolver.resolveConflicts(List<DomainEventMessage> appliedChanges,
List<DomainEventMessage> committedChanges)
Checks the given list of
appliedChanges and committedChanges for any conflicting
changes. |
Modifier and Type | Method and Description |
---|---|
void |
SnapshotEventStore.appendSnapshotEvent(String type,
DomainEventMessage snapshotEvent)
Append the given
snapshotEvent to the snapshot event log for the given type type . |
void |
EventVisitor.doWithEvent(DomainEventMessage domainEvent)
Called for each event loaded by the event store.
|
Modifier and Type | Method and Description |
---|---|
DomainEventMessage |
FileSystemBufferedReaderDomainEventStream.next() |
DomainEventMessage |
FileSystemBufferedReaderDomainEventStream.peek() |
DomainEventMessage |
FileSystemSnapshotEventReader.readSnapshotEvent(String type,
Object identifier)
Reads the latest snapshot of the given aggregate identifier.
|
Modifier and Type | Method and Description |
---|---|
void |
FileSystemEventStore.appendSnapshotEvent(String type,
DomainEventMessage snapshotEvent)
Append the given
snapshotEvent to the snapshot event log for the given type type . |
void |
FileSystemEventMessageWriter.writeEventMessage(DomainEventMessage eventMessage)
Writes the given
eventMessage to the underling output. |
void |
FileSystemSnapshotEventWriter.writeSnapshotEvent(DomainEventMessage snapshotEvent)
Writes the given snapshotEvent to the
FileSystemSnapshotEventWriter.snapshotEventFile . |
Modifier and Type | Method and Description |
---|---|
void |
JpaEventStore.appendSnapshotEvent(String type,
DomainEventMessage snapshotEvent)
Append the given
snapshotEvent to the snapshot event log for the given type type . |
void |
EventEntryStore.persistEvent(String aggregateType,
DomainEventMessage event,
SerializedObject serializedPayload,
SerializedObject serializedMetaData,
javax.persistence.EntityManager entityManager)
Persists the given
event which has been serialized into serializedEvent in the
backing data store using given entityManager . |
void |
DefaultEventEntryStore.persistEvent(String aggregateType,
DomainEventMessage event,
SerializedObject serializedPayload,
SerializedObject serializedMetaData,
javax.persistence.EntityManager entityManager) |
void |
EventEntryStore.persistSnapshot(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject serializedPayload,
SerializedObject serializedMetaData,
javax.persistence.EntityManager entityManager)
Persists the given
event which has been serialized into serializedEvent in the
backing data store using given entityManager . |
void |
DefaultEventEntryStore.persistSnapshot(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject serializedPayload,
SerializedObject serializedMetaData,
javax.persistence.EntityManager entityManager) |
void |
EventEntryStore.pruneSnapshots(String type,
DomainEventMessage mostRecentSnapshotEvent,
int maxSnapshotsArchived,
javax.persistence.EntityManager entityManager)
Removes old snapshots from the storage for an aggregate of given
type that generated the given
mostRecentSnapshotEvent . |
void |
DefaultEventEntryStore.pruneSnapshots(String type,
DomainEventMessage mostRecentSnapshotEvent,
int maxSnapshotsArchived,
javax.persistence.EntityManager entityManager) |
Constructor and Description |
---|
AbstractEventEntry(String type,
DomainEventMessage event,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
DomainEventEntry(String type,
DomainEventMessage event,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
SnapshotEventEntry(String type,
DomainEventMessage event,
SerializedObject payload,
SerializedObject metaData)
Initialize an Event entry for the given
event . |
Modifier and Type | Method and Description |
---|---|
List<DomainEventMessage> |
StorageStrategy.extractEventMessages(com.mongodb.DBObject entry,
Object aggregateIdentifier,
Serializer serializer,
UpcasterChain upcasterChain)
Extracts the individual Event Messages from the given
entry . |
List<DomainEventMessage> |
DocumentPerEventStorageStrategy.extractEventMessages(com.mongodb.DBObject entry,
Object aggregateIdentifier,
Serializer serializer,
UpcasterChain upcasterChain) |
List<DomainEventMessage> |
DocumentPerCommitStorageStrategy.extractEventMessages(com.mongodb.DBObject entry,
Object aggregateIdentifier,
Serializer serializer,
UpcasterChain upcasterChain) |
Modifier and Type | Method and Description |
---|---|
void |
MongoEventStore.appendSnapshotEvent(String type,
DomainEventMessage snapshotEvent) |
Modifier and Type | Method and Description |
---|---|
com.mongodb.DBObject[] |
StorageStrategy.createDocuments(String type,
Serializer eventSerializer,
List<DomainEventMessage> messages)
Generates the DBObject instances that need to be stored for a commit.
|
com.mongodb.DBObject[] |
DocumentPerEventStorageStrategy.createDocuments(String type,
Serializer eventSerializer,
List<DomainEventMessage> messages) |
com.mongodb.DBObject[] |
DocumentPerCommitStorageStrategy.createDocuments(String type,
Serializer eventSerializer,
List<DomainEventMessage> messages) |
Modifier and Type | Method and Description |
---|---|
List<DomainEventMessage> |
EventEntry.getDomainEvent(Object actualAggregateIdentifier,
Serializer serializer,
UpcasterChain upcasterChain)
Returns the actual DomainEvent from the EventEntry using the provided Serializer.
|
Modifier and Type | Method and Description |
---|---|
void |
GaeEventStore.appendSnapshotEvent(String type,
DomainEventMessage snapshotEvent) |
Modifier and Type | Method and Description |
---|---|
protected void |
ToDoItem.handle(DomainEventMessage eventMessage) |
Modifier and Type | Class and Description |
---|---|
class |
SerializationAwareDomainEventMessage<T>
Wrapper around a DomainEventMessage that adds "Serialization Awareness" to the message it wraps.
|
class |
SerializedDomainEventMessage<T>
DomainEventMessage implementation that is optimized to cope with serialized Payload and MetaData.
|
Modifier and Type | Method and Description |
---|---|
DomainEventMessage<T> |
SerializedDomainEventMessage.andMetaData(Map<String,?> additionalMetaData)
Returns a copy of this DomainEventMessage with its MetaData merged with the given
metaData . |
DomainEventMessage<T> |
SerializationAwareDomainEventMessage.andMetaData(Map<String,?> metaData) |
DomainEventMessage<T> |
SerializedDomainEventMessage.withMetaData(Map<String,?> newMetaData) |
DomainEventMessage<T> |
SerializationAwareDomainEventMessage.withMetaData(Map<String,?> metaData) |
static <T> DomainEventMessage<T> |
SerializationAwareDomainEventMessage.wrap(DomainEventMessage<T> message)
Wrap the given
message to make it SerializationAware. |
Modifier and Type | Method and Description |
---|---|
static <T> DomainEventMessage<T> |
SerializationAwareDomainEventMessage.wrap(DomainEventMessage<T> message)
Wrap the given
message to make it SerializationAware. |
Constructor and Description |
---|
SerializationAwareDomainEventMessage(DomainEventMessage<T> message)
Initialize a new wrapper for the given
message . |
Modifier and Type | Method and Description |
---|---|
void |
Reporter.reportDifferenceInStoredVsPublished(Collection<DomainEventMessage> storedEvents,
Collection<EventMessage> publishedEvents,
Throwable probableCause)
Report a failed assertion due to a difference in the stored versus the published events.
|
Constructor and Description |
---|
ResultValidatorImpl(Collection<DomainEventMessage> storedEvents,
Collection<EventMessage> publishedEvents)
Initialize the ResultValidatorImpl with the given
storedEvents and publishedEvents . |
Copyright © 2010-2013. All Rights Reserved.