org.axonframework.amqp.eventhandling.legacy

Class JavaSerializationAMQPMessageConverter

java.lang.Object

org.axonframework.amqp.eventhandling.legacy.JavaSerializationAMQPMessageConverter

All Implemented Interfaces:

AMQPMessageConverter

public class JavaSerializationAMQPMessageConverter
extends Object
implements AMQPMessageConverter

Implementation of the AMQPMessageConverter interface that serializes the Message using Java Serialization, while the payload and meta data of the messages are serialized using the configured Serializer.

This class is not the recommended approach, as it doesn't play well with non-axon consumers. It is available for backwards compatibility reasons, as this implementation was the default in Axon 2.

Author:

Allard Buijze

Constructor Summary

Constructors

Constructor and Description
JavaSerializationAMQPMessageConverter(Serializer serializer) Initializes the AMQPMessageConverter with the given serializer, using a PackageRoutingKeyResolver and requesting durable dispatching.
JavaSerializationAMQPMessageConverter(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

JavaSerializationAMQPMessageConverter

public JavaSerializationAMQPMessageConverter(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 and Meta Data with

JavaSerializationAMQPMessageConverter

public JavaSerializationAMQPMessageConverter(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