org.axonframework.amqp.eventhandling

Class DefaultAMQPMessageConverter

java.lang.Object

org.axonframework.amqp.eventhandling.DefaultAMQPMessageConverter

All Implemented Interfaces:

AMQPMessageConverter

public class DefaultAMQPMessageConverter
extends Object
implements AMQPMessageConverter

Default implementation of the AMQPMessageConverter interface. This implementation will suffice in most cases. It passes all meta-data entries as headers (with 'axon-metadata-' prefix) to the message. Other message-specific attributes are also added as meta data. The message payload is serialized using the configured serializer and passed as the message body.

Author:

Allard Buijze

Constructor Summary

Constructors

Constructor and Description
DefaultAMQPMessageConverter(Serializer serializer) Initializes the AMQPMessageConverter with the given serializer, using a PackageRoutingKeyResolver and requesting durable dispatching.
DefaultAMQPMessageConverter(Serializer serializer, RoutingKeyResolver routingKeyResolver, boolean durable) Initializes the AMQPMessageConverter with the given serializer, routingKeyResolver and requesting durable dispatching when durable is true.

Method Summary

Modifier and Type	Method and Description
AMQPMessage	createAMQPMessage(EventMessage<?> eventMessage) Creates an AMQPMessage from given eventMessage.
Optional<EventMessage<?>>	readAMQPMessage(byte[] messageBody, Map<String,Object> headers) Reconstruct an EventMessage from the given messageBody and headers.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultAMQPMessageConverter

public DefaultAMQPMessageConverter(Serializer serializer)

Initializes the AMQPMessageConverter with the given serializer, using a PackageRoutingKeyResolver and requesting durable dispatching.

Parameters:

serializer - The serializer to serialize the Event Message's payload with

DefaultAMQPMessageConverter

public DefaultAMQPMessageConverter(Serializer serializer,
                                   RoutingKeyResolver routingKeyResolver,
                                   boolean durable)

Initializes the AMQPMessageConverter with the given serializer, routingKeyResolver and requesting durable dispatching when durable is true.

Parameters:

serializer - The serializer to serialize the Event Message's payload and Meta Data with

routingKeyResolver - The strategy to use to resolve routing keys for Event Messages

durable - Whether to request durable message dispatching

Method Detail

createAMQPMessage

public AMQPMessage createAMQPMessage(EventMessage<?> eventMessage)

Description copied from interface: AMQPMessageConverter

Creates an AMQPMessage from given eventMessage.

Specified by:

createAMQPMessage in interface AMQPMessageConverter

Parameters:

eventMessage - The EventMessage to create the AMQP Message from

Returns:

an AMQP Message containing the data and characteristics of the Message to send to the AMQP Message Broker.

readAMQPMessage

public Optional<EventMessage<?>> readAMQPMessage(byte[] messageBody,
                                                 Map<String,Object> headers)

Description copied from interface: AMQPMessageConverter

Reconstruct an EventMessage from the given messageBody and headers. The returned optional resolves to a message if the given input parameters represented a correct event message.

Specified by:

readAMQPMessage in interface AMQPMessageConverter

Parameters:

messageBody - The body of the AMQP Message

headers - The headers attached to the AMQP Message

Returns:

The Event Message to publish on the local event processors