org.axonframework.eventsourcing

Class GenericDomainEventMessage<T>

java.lang.Object

org.axonframework.messaging.MessageDecorator<T>

org.axonframework.eventhandling.GenericEventMessage<T>

org.axonframework.eventsourcing.GenericDomainEventMessage<T>

Type Parameters:

T - The type of payload contained in this Message

All Implemented Interfaces:

Serializable, EventMessage<T>, DomainEventMessage<T>, Message<T>, SerializationAware

Direct Known Subclasses:

GenericTrackedDomainEventMessage

public class GenericDomainEventMessage<T>
extends GenericEventMessage<T>
implements DomainEventMessage<T>

Generic implementation of a DomainEventMessage.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.axonframework.eventhandling.GenericEventMessage

clock

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GenericDomainEventMessage(String type, String aggregateIdentifier, long sequenceNumber, Message<T> delegate, Instant timestamp) Initialize a DomainEventMessage originating from an Aggregate with the given aggregateIdentifier, with given sequenceNumber and payload, metaData and timestamp.
	GenericDomainEventMessage(String type, String aggregateIdentifier, long sequenceNumber, Message<T> delegate, Supplier<Instant> timestamp) Initialize a DomainEventMessage originating from an Aggregate using existing data.
	GenericDomainEventMessage(String type, String aggregateIdentifier, long sequenceNumber, T payload) Initialize a DomainEventMessage originating from an Aggregate with the given aggregateIdentifier, with given sequenceNumber and payload.
	GenericDomainEventMessage(String type, String aggregateIdentifier, long sequenceNumber, T payload, Map<String,?> metaData) Initialize a DomainEventMessage originating from an Aggregate with the given aggregateIdentifier, with given sequenceNumber and payload and metaData.
	GenericDomainEventMessage(String type, String aggregateIdentifier, long sequenceNumber, T payload, Map<String,?> metaData, String messageIdentifier, Instant timestamp) Initialize a DomainEventMessage originating from an Aggregate using existing data.

Method Summary

Modifier and Type	Method and Description
GenericDomainEventMessage<T>	andMetaData(Map<String,?> metaData) Returns a copy of this EventMessage with it MetaData merged with the given metaData.
String	getAggregateIdentifier() Returns the identifier of the Aggregate that generated this DomainEvent.
long	getSequenceNumber() Returns the sequence number that allows DomainEvents originating from the same Aggregate to be placed in the order of generation.
String	getType() Returns the type of the Aggregate that generated this DomainEvent.
GenericDomainEventMessage<T>	withMetaData(Map<String,?> metaData) Returns a copy of this EventMessage with the given metaData.

Methods inherited from class org.axonframework.eventhandling.GenericEventMessage

asEventMessage, getTimestamp

Methods inherited from class org.axonframework.messaging.MessageDecorator

getDelegate, getIdentifier, getMetaData, getPayload, getPayloadType, serializeMetaData, serializePayload

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.axonframework.eventhandling.EventMessage

getIdentifier, getTimestamp

Methods inherited from interface org.axonframework.messaging.Message

getMetaData, getPayload, getPayloadType

Constructor Detail

GenericDomainEventMessage

public GenericDomainEventMessage(String type,
                                 String aggregateIdentifier,
                                 long sequenceNumber,
                                 T payload)

Initialize a DomainEventMessage originating from an Aggregate with the given aggregateIdentifier, with given sequenceNumber and payload. The MetaData of the message is empty.

Parameters:

type - The domain type

aggregateIdentifier - The identifier of the aggregate generating this message

sequenceNumber - The message's sequence number

payload - The application-specific payload of the message

GenericDomainEventMessage

public GenericDomainEventMessage(String type,
                                 String aggregateIdentifier,
                                 long sequenceNumber,
                                 T payload,
                                 Map<String,?> metaData)

Initialize a DomainEventMessage originating from an Aggregate with the given aggregateIdentifier, with given sequenceNumber and payload and metaData.

Parameters:

type - The domain type

aggregateIdentifier - The identifier of the aggregate generating this message

sequenceNumber - The message's sequence number

payload - The application-specific payload of the message

metaData - The MetaData to attach to the message

GenericDomainEventMessage

public GenericDomainEventMessage(String type,
                                 String aggregateIdentifier,
                                 long sequenceNumber,
                                 T payload,
                                 Map<String,?> metaData,
                                 String messageIdentifier,
                                 Instant timestamp)

Initialize a DomainEventMessage originating from an Aggregate using existing data.

Parameters:

type - The domain type

aggregateIdentifier - The identifier of the aggregate generating this message

sequenceNumber - The message's sequence number

payload - The application-specific payload of the message

metaData - The MetaData to attach to the message

messageIdentifier - The message identifier

timestamp - The event's timestamp

GenericDomainEventMessage

public GenericDomainEventMessage(String type,
                                 String aggregateIdentifier,
                                 long sequenceNumber,
                                 Message<T> delegate,
                                 Supplier<Instant> timestamp)

Initialize a DomainEventMessage originating from an Aggregate using existing data. The timestamp of the event is supplied lazily to prevent unnecessary deserialization of the timestamp.

Parameters:

type - The domain type

aggregateIdentifier - The identifier of the aggregate generating this message

sequenceNumber - The message's sequence number

delegate - The delegate message providing the payload, metadata and identifier of the event

timestamp - The event's timestamp supplier

GenericDomainEventMessage

protected GenericDomainEventMessage(String type,
                                    String aggregateIdentifier,
                                    long sequenceNumber,
                                    Message<T> delegate,
                                    Instant timestamp)

Initialize a DomainEventMessage originating from an Aggregate with the given aggregateIdentifier, with given sequenceNumber and payload, metaData and timestamp.

Parameters:

type - the aggregate type

aggregateIdentifier - the aggregate identifier

sequenceNumber - the sequence number of the event

delegate - The delegate message providing the payload, metadata and identifier of the event

timestamp - the timestamp of the event

Method Detail

getType

public String getType()

Description copied from interface: DomainEventMessage

Returns the type of the Aggregate that generated this DomainEvent. By default this is equal to the simple class name of the aggregate root.

Specified by:

getType in interface DomainEventMessage<T>

Returns:

the type of the Aggregate that generated this DomainEvent

getAggregateIdentifier

public String getAggregateIdentifier()

Description copied from interface: DomainEventMessage

Returns the identifier of the Aggregate that generated this DomainEvent. Note that the value returned does not necessarily have to be the same instance that was provided at creation time. It is possible that (due to serialization, for example) the value returned here has a different structure.

Specified by:

getAggregateIdentifier in interface DomainEventMessage<T>

Returns:

the identifier of the Aggregate that generated this DomainEvent

getSequenceNumber

public long getSequenceNumber()

Description copied from interface: DomainEventMessage

Returns the sequence number that allows DomainEvents originating from the same Aggregate to be placed in the order of generation.

Specified by:

getSequenceNumber in interface DomainEventMessage<T>

Returns:

the sequence number of this Event

withMetaData

public GenericDomainEventMessage<T> withMetaData(Map<String,?> metaData)

Description copied from interface: EventMessage

Returns a copy of this EventMessage with the given metaData. The payload, Timestamp and Identifier remain unchanged.

Specified by:

withMetaData in interface EventMessage<T>

Specified by:

withMetaData in interface DomainEventMessage<T>

Specified by:

withMetaData in interface Message<T>

Overrides:

withMetaData in class GenericEventMessage<T>

Parameters:

metaData - The new MetaData for the Message

Returns:

a copy of this message with the given MetaData

andMetaData

public GenericDomainEventMessage<T> andMetaData(Map<String,?> metaData)

Description copied from interface: EventMessage

Returns a copy of this EventMessage with it MetaData merged with the given metaData. The payload, Timestamp and Identifier remain unchanged.

Specified by:

andMetaData in interface EventMessage<T>

Specified by:

andMetaData in interface DomainEventMessage<T>

Specified by:

andMetaData in interface Message<T>

Overrides:

andMetaData in class GenericEventMessage<T>

Parameters:

metaData - The MetaData to merge with

Returns:

a copy of this message with the given MetaData