Package org.springframework.integration.amqp.support

Class MappingUtils

java.lang.Object

org.springframework.integration.amqp.support.MappingUtils

public final class MappingUtils
extends Object

Utility methods used during message mapping.

Since:

4.3

Author:

Gary Russell, Artem Bilan

Method Summary

Modifier and Type	Method	Description
static void	checkDeliveryMode(Message<?> requestMessage, MessageProperties messageProperties, MessageDeliveryMode defaultDeliveryMode)	Check the delivery mode and update with the default if not already present.
static Message	mapMessage(Message<?> message, MessageConverter converter, AmqpHeaderMapper headerMapper, boolean headersMappedLast, boolean reply, MessageProperties amqpMessageProperties)	Map a reply o.s.m.Message to an o.s.a.core.Message.
static Message	mapMessage(Message<?> requestMessage, MessageConverter converter, AmqpHeaderMapper headerMapper, MessageDeliveryMode defaultDeliveryMode, boolean headersMappedLast)	Map an o.s.m.Message to an o.s.a.core.Message.
static Message	mapReplyMessage(Message<?> replyMessage, MessageConverter converter, AmqpHeaderMapper headerMapper, MessageDeliveryMode defaultDeliveryMode, boolean headersMappedLast)	Map a reply o.s.m.Message to an o.s.a.core.Message.

Methods inherited from class java.lang.Object

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

Method Details

mapMessage

public static Message mapMessage(Message<?> requestMessage,
 MessageConverter converter,
 AmqpHeaderMapper headerMapper,
 MessageDeliveryMode defaultDeliveryMode,
 boolean headersMappedLast)

Map an o.s.m.Message to an o.s.a.core.Message. When using a ContentTypeDelegatingMessageConverter, AmqpHeaders.CONTENT_TYPE and MessageHeaders.CONTENT_TYPE will be used for the selection, with the AMQP header taking precedence.

Parameters:

requestMessage - the request message.

converter - the message converter to use.

headerMapper - the header mapper to use.

defaultDeliveryMode - the default delivery mode.

headersMappedLast - true if headers are mapped after conversion.

Returns:

the mapped Message.

mapReplyMessage

public static Message mapReplyMessage(Message<?> replyMessage,
 MessageConverter converter,
 AmqpHeaderMapper headerMapper,
 @Nullable
 MessageDeliveryMode defaultDeliveryMode,
 boolean headersMappedLast)

Map a reply o.s.m.Message to an o.s.a.core.Message. When using a ContentTypeDelegatingMessageConverter, AmqpHeaders.CONTENT_TYPE and MessageHeaders.CONTENT_TYPE will be used for the selection, with the AMQP header taking precedence.

Parameters:

replyMessage - the reply message.

converter - the message converter to use.

headerMapper - the header mapper to use.

defaultDeliveryMode - the default delivery mode.

headersMappedLast - true if headers are mapped after conversion.

Returns:

the mapped Message.

Since:

5.1.9

mapMessage

public static Message mapMessage(Message<?> message,
 MessageConverter converter,
 AmqpHeaderMapper headerMapper,
 boolean headersMappedLast,
 boolean reply,
 MessageProperties amqpMessageProperties)

Map a reply o.s.m.Message to an o.s.a.core.Message. When using a ContentTypeDelegatingMessageConverter, AmqpHeaders.CONTENT_TYPE and MessageHeaders.CONTENT_TYPE will be used for the selection, with the AMQP header taking precedence.

Parameters:

replyMessage - the reply message.

converter - the message converter to use.

headerMapper - the header mapper to use.

headersMappedLast - true if headers are mapped after conversion.

Returns:

the mapped Message.

Since:

6.0

checkDeliveryMode

public static void checkDeliveryMode(Message<?> requestMessage,
 MessageProperties messageProperties,
 @Nullable
 MessageDeliveryMode defaultDeliveryMode)

Check the delivery mode and update with the default if not already present.

Parameters:

requestMessage - the request message.

messageProperties - the mapped message properties.

defaultDeliveryMode - the default delivery mode.