org.springframework.amqp.support.converter

Class MessagingMessageConverter

java.lang.Object

org.springframework.amqp.support.converter.MessagingMessageConverter

All Implemented Interfaces:

MessageConverter, org.springframework.beans.factory.InitializingBean

public class MessagingMessageConverter
extends java.lang.Object
implements MessageConverter, org.springframework.beans.factory.InitializingBean

Convert a Message from the messaging abstraction to and from a Message using an underlying MessageConverter for the payload and a AmqpHeaderMapper to map the AMQP headers to and from standard message headers.

The inbound flag determines how headers should be mapped. If true (default), the caller is an inbound listener (i.e. parsing an AMQP message is considered to be a request).

Since:

1.4

Author:

Stephane Nicoll

Constructor Summary

Constructors

Constructor and Description
MessagingMessageConverter() Create an instance with a default payload converter for an inbound handler.
MessagingMessageConverter(MessageConverter payloadConverter, AmqpHeaderMapper headerMapper) Create an instance with the specified payload converter and header mapper.

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
protected java.lang.Object	extractPayload(Message message) Extract the payload of the specified Message.
java.lang.Object	fromMessage(Message message) Convert from a Message to a Java object.
void	setHeaderMapper(AmqpHeaderMapper headerMapper) Set the AmqpHeaderMapper to use to map AMQP headers to and from standard message headers.
void	setPayloadConverter(MessageConverter payloadConverter) Set the MessageConverter to use to convert the payload.
Message	toMessage(java.lang.Object object, MessageProperties messageProperties) Convert a Java object to a Message.

Methods inherited from class java.lang.Object

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

Constructor Detail

MessagingMessageConverter

public MessagingMessageConverter()

Create an instance with a default payload converter for an inbound handler.

See Also:

SimpleMessageConverter, SimpleAmqpHeaderMapper

MessagingMessageConverter

public MessagingMessageConverter(MessageConverter payloadConverter,
                                 AmqpHeaderMapper headerMapper)

Create an instance with the specified payload converter and header mapper.

Parameters:

payloadConverter - the target MessageConverter for payload.

headerMapper - the AmqpHeaderMapper to map AMQP header to MessageHeaders.

Method Detail

setPayloadConverter

public void setPayloadConverter(MessageConverter payloadConverter)

Set the MessageConverter to use to convert the payload.

Parameters:

payloadConverter - the target MessageConverter for payload.

setHeaderMapper

public void setHeaderMapper(AmqpHeaderMapper headerMapper)

Set the AmqpHeaderMapper to use to map AMQP headers to and from standard message headers.

Parameters:

headerMapper - the AmqpHeaderMapper to map AMQP header to MessageHeaders.

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

toMessage

public Message toMessage(java.lang.Object object,
                         MessageProperties messageProperties)
                  throws MessageConversionException

Description copied from interface: MessageConverter

Convert a Java object to a Message.

Specified by:

toMessage in interface MessageConverter

Parameters:

object - the object to convert

messageProperties - The message properties.

Returns:

the Message

Throws:

MessageConversionException - in case of conversion failure

fromMessage

public java.lang.Object fromMessage(Message message)
                             throws MessageConversionException

Description copied from interface: MessageConverter

Convert from a Message to a Java object.

Specified by:

fromMessage in interface MessageConverter

Parameters:

message - the message to convert

Returns:

the converted Java object

Throws:

MessageConversionException - in case of conversion failure

extractPayload

protected java.lang.Object extractPayload(Message message)

Extract the payload of the specified Message.

Parameters:

message - the AMQP Message to extract payload.

Returns:

the extracted payload.