Package org.axonframework.eventhandling.deadletter.jpa

Class EventMessageDeadLetterJpaConverter

java.lang.Object

org.axonframework.eventhandling.deadletter.jpa.EventMessageDeadLetterJpaConverter

All Implemented Interfaces:

DeadLetterJpaConverter<EventMessage<?>>

public class EventMessageDeadLetterJpaConverter
extends Object
implements DeadLetterJpaConverter<EventMessage<?>>

Converter responsible for converting to and from known EventMessage implementations that should be supported by a SequencedDeadLetterQueue capable of storing EventMessages.

It rebuilds the original message implementation by checking which properties were extracted when it was originally mapped. For example, if the aggregate type and token are present, it will construct a GenericTrackedDomainEventMessage.

Since:

4.6.0

Author:

Mitchell Herrijgers

Constructor Summary

Constructors

Constructor	Description
EventMessageDeadLetterJpaConverter()

Method Summary

Modifier and Type	Method	Description
boolean	canConvert(DeadLetterEventEntry message)	Check whether this converter supports the given DeadLetterEventEntry.
boolean	canConvert(EventMessage<?> message)	Check whether this converter supports the given EventMessage.
EventMessage<?>	convert(DeadLetterEventEntry entry, Serializer eventSerializer, Serializer genericSerializer)	Converts a DeadLetterEventEntry to a EventMessage implementation.
DeadLetterEventEntry	convert(EventMessage<?> message, Serializer eventSerializer, Serializer genericSerializer)	Converts an EventMessage implementation to a DeadLetterEventEntry.

Methods inherited from class java.lang.Object

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

Constructor Details

EventMessageDeadLetterJpaConverter

public EventMessageDeadLetterJpaConverter()

Method Details

convert

public DeadLetterEventEntry convert(EventMessage<?> message,
 Serializer eventSerializer,
 Serializer genericSerializer)

Description copied from interface: DeadLetterJpaConverter

Converts an EventMessage implementation to a DeadLetterEventEntry.

Specified by:

convert in interface DeadLetterJpaConverter<EventMessage<?>>

Parameters:

message - The message to convert.

eventSerializer - The Serializer for serialization of payload and metadata.

genericSerializer - The Serializer for serialization of the token, if present.

Returns:

The created DeadLetterEventEntry

convert

public EventMessage<?> convert(DeadLetterEventEntry entry,
 Serializer eventSerializer,
 Serializer genericSerializer)

Description copied from interface: DeadLetterJpaConverter

Converts a DeadLetterEventEntry to a EventMessage implementation.

Specified by:

convert in interface DeadLetterJpaConverter<EventMessage<?>>

Parameters:

entry - The database entry to convert to a EventMessage

eventSerializer - The Serializer for deserialization of payload and metadata.

genericSerializer - The Serializer for deserialization of the token, if present.

Returns:

The created DeadLetterEventEntry

canConvert

public boolean canConvert(DeadLetterEventEntry message)

Description copied from interface: DeadLetterJpaConverter

Check whether this converter supports the given DeadLetterEventEntry.

Specified by:

canConvert in interface DeadLetterJpaConverter<EventMessage<?>>

Parameters:

message - The message to check support for.

Returns:

Whether the provided message is supported by this converter.

canConvert

public boolean canConvert(EventMessage<?> message)

Description copied from interface: DeadLetterJpaConverter

Check whether this converter supports the given EventMessage.

Specified by:

canConvert in interface DeadLetterJpaConverter<EventMessage<?>>

Parameters:

message - The message to check support for.

Returns:

Whether the provided message is supported by this converter.