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 |
---|---|
List<EventMessage> |
IncomingMessageHandler.releaseMessage(Cluster destination,
DomainEventMessage message)
Invoked when a message has been replayed from the event store.
|
List<EventMessage> |
DiscardingIncomingMessageHandler.releaseMessage(Cluster destination,
DomainEventMessage message) |
List<EventMessage> |
BackloggingIncomingMessageHandler.releaseMessage(Cluster destination,
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 handler method with the provided event.
|
protected void |
AbstractAnnotatedAggregateRoot.handle(DomainEventMessage event)
Calls the appropriate handler method 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 |
JdbcEventStore.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<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Stores the given
event (serialized as serializedPayload and
serializedMetaData in the Event Store. |
void |
DefaultEventEntryStore.persistEvent(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData) |
void |
EventEntryStore.persistSnapshot(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Persists the given
event which has been serialized into serializedEvent . |
void |
DefaultEventEntryStore.persistSnapshot(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData) |
void |
EventEntryStore.pruneSnapshots(String type,
DomainEventMessage mostRecentSnapshotEvent,
int maxSnapshotsArchived)
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) |
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 . |
Object |
DefaultEventEntryFactory.createDomainEventEntry(String aggregateType,
DomainEventMessage event,
SerializedObject<byte[]> serializedPayload,
SerializedObject<byte[]> serializedMetaData) |
Object |
EventEntryFactory.createDomainEventEntry(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Creates an entity representing a Domain Event, which contains the data provided in the parameters, which can be
stored using the JPA Entity Manager configured on the JpaEventStore using this factory.
|
protected Object |
DefaultEventEntryStore.createDomainEventEntry(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Allows for customization of the DomainEventEntry to store.
|
Object |
DefaultEventEntryFactory.createSnapshotEventEntry(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<byte[]> serializedPayload,
SerializedObject<byte[]> serializedMetaData) |
Object |
EventEntryFactory.createSnapshotEventEntry(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Creates an entity representing a Snapshot Event, which contains the data provided in the parameters, which can
be stored using the JPA Entity Manager configured on the JpaEventStore using this factory.
|
protected Object |
DefaultEventEntryStore.createSnapshotEventEntry(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> serializedMetaData)
Allows for customization of the SnapshotEventEntry to store.
|
void |
EventEntryStore.persistEvent(String aggregateType,
DomainEventMessage event,
SerializedObject<T> serializedPayload,
SerializedObject<T> 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<T> serializedPayload,
SerializedObject<T> serializedMetaData,
javax.persistence.EntityManager entityManager) |
void |
EventEntryStore.persistSnapshot(String aggregateType,
DomainEventMessage snapshotEvent,
SerializedObject<T> serializedPayload,
SerializedObject<T> 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<T> serializedPayload,
SerializedObject<T> 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,
org.joda.time.DateTime timestamp,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
AbstractEventEntry(String type,
DomainEventMessage event,
SerializedObject<byte[]> payload,
SerializedObject<byte[]> metaData)
Initialize an Event entry for the given
event . |
DomainEventEntry(String type,
DomainEventMessage event,
org.joda.time.DateTime dateTime,
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<byte[]> payload,
SerializedObject<byte[]> 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,
boolean skipUnknownTypes)
Extracts the individual Event Messages from the given
entry . |
List<DomainEventMessage> |
DocumentPerEventStorageStrategy.extractEventMessages(com.mongodb.DBObject entry,
Object aggregateIdentifier,
Serializer serializer,
UpcasterChain upcasterChain,
boolean skipUnknownTypes) |
List<DomainEventMessage> |
DocumentPerCommitStorageStrategy.extractEventMessages(com.mongodb.DBObject entry,
Object aggregateIdentifier,
Serializer serializer,
UpcasterChain upcasterChain,
boolean skipUnknownTypes) |
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,
boolean skipUnknownTypes)
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 . |
Modifier and Type | Method and Description |
---|---|
static List<DomainEventMessage> |
UpcastUtils.upcastAndDeserialize(SerializedDomainEventData entry,
Object aggregateIdentifier,
Serializer serializer,
UpcasterChain upcasterChain,
boolean skipUnknownTypes)
Upcasts and deserializes the given
entry using the given serializer and
upcasterChain . |
Copyright © 2010-2014. All Rights Reserved.