Package org.axonframework.eventhandling.deadletter.jpa

Class DeadLetterEventEntry

java.lang.Object

org.axonframework.eventhandling.deadletter.jpa.DeadLetterEventEntry

@Embeddable
@Embeddable
public class DeadLetterEventEntry
extends Object

Represents an EventMessage when stored into the database. It contains all properties known in the framework implementations. Based on which properties are present, the original message type can be determined. For example, if an aggregate identifier is present, it was a DomainEventMessage.

Since:

4.6.0

Author:

Mitchell Herrijgers

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DeadLetterEventEntry()
	DeadLetterEventEntry(String messageType, String messageIdentifier, String messageTimestamp, String payloadType, String payloadRevision, byte[] payload, byte[] metaData, String aggregateType, String aggregateIdentifier, Long sequenceNumber, String tokenType, byte[] token)	Constructs a new DeadLetterEventEntry using the provided parameters.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
String	getAggregateIdentifier()	Returns the original DomainEventMessage.getAggregateIdentifier(), if it was a DomainEventMessage.
String	getEventIdentifier()	Returns the original EventMessage.getIdentifier().
String	getMessageType()	Returns the message type, which is defined by the DeadLetterJpaConverter that mapped this entry.
SimpleSerializedObject<byte[]>	getMetaData()	Returns the original metadata as a SimpleSerializedObject.
SimpleSerializedObject<byte[]>	getPayload()	Returns the original payload as a SimpleSerializedObject.
Long	getSequenceNumber()	Returns the original DomainEventMessage.getSequenceNumber(), if it was a DomainEventMessage.
String	getTimeStamp()	Returns the original EventMessage.getTimestamp().
SimpleSerializedObject<byte[]>	getTrackingToken()	Returns the original TrackedEventMessage.trackingToken() as a SerializedObject, if the original message was a TrackedEventMessage.
String	getType()	Returns the original DomainEventMessage.getType(), if it was a DomainEventMessage.
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

DeadLetterEventEntry

protected DeadLetterEventEntry()

DeadLetterEventEntry

public DeadLetterEventEntry(String messageType,
 String messageIdentifier,
 String messageTimestamp,
 String payloadType,
 String payloadRevision,
 byte[] payload,
 byte[] metaData,
 String aggregateType,
 String aggregateIdentifier,
 Long sequenceNumber,
 String tokenType,
 byte[] token)

Constructs a new DeadLetterEventEntry using the provided parameters. Parameters can be null if it's not relevant for the messageType. For example, a DomainEventMessage contains an aggregateType, aggregateIdentifier and sequenceNumber, but a GenericEventMessage does not.

Parameters:

messageType - The message type (required).

messageIdentifier - The identifier of the message (required).

messageTimestamp - The timestamp of the message (required).

payloadType - The payload's type of the message.

payloadRevision - The payload's revision of the message.

payload - The serialized payload of the message.

metaData - The serialized metadata of the message.

aggregateType - The aggregate type of the message.

aggregateIdentifier - The aggregate identifier of the message.

sequenceNumber - The aggregate sequence number of the message.

tokenType - The type of tracking token the message.

token - The serialized tracking token.

Method Details

getMessageType

public String getMessageType()

Returns the message type, which is defined by the DeadLetterJpaConverter that mapped this entry. Used for later matching whether a converter can convert it back to an EventMessage.

Returns:

The message type.

getEventIdentifier

public String getEventIdentifier()

Returns the original EventMessage.getIdentifier().

Returns:

The event identifier.

getTimeStamp

public String getTimeStamp()

Returns the original EventMessage.getTimestamp().

Returns:

The event timestamp.

getPayload

public SimpleSerializedObject<byte[]> getPayload()

Returns the original payload as a SimpleSerializedObject.

Returns:

The original payload.

getMetaData

public SimpleSerializedObject<byte[]> getMetaData()

Returns the original metadata as a SimpleSerializedObject.

Returns:

The original metadata.

getType

public String getType()

Returns the original DomainEventMessage.getType(), if it was a DomainEventMessage.

Returns:

The original aggregate type.

getAggregateIdentifier

public String getAggregateIdentifier()

Returns the original DomainEventMessage.getAggregateIdentifier(), if it was a DomainEventMessage.

Returns:

The original aggregate identifier.

getSequenceNumber

public Long getSequenceNumber()

Returns the original DomainEventMessage.getSequenceNumber(), if it was a DomainEventMessage.

Returns:

The original aggregate sequence number.

getTrackingToken

public SimpleSerializedObject<byte[]> getTrackingToken()

Returns the original TrackedEventMessage.trackingToken() as a SerializedObject, if the original message was a TrackedEventMessage.

Returns:

The original tracking token.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object