org.springframework.amqp.rabbit.support

Class DefaultMessagePropertiesConverter

java.lang.Object

org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter

All Implemented Interfaces:

MessagePropertiesConverter

public class DefaultMessagePropertiesConverter
extends java.lang.Object
implements MessagePropertiesConverter

Default implementation of the MessagePropertiesConverter strategy.

Since:

1.0

Constructor Summary

Constructors

Constructor and Description
DefaultMessagePropertiesConverter()

Method Summary

Modifier and Type	Method and Description
private java.util.Map<java.lang.String,java.lang.Object>	convertHeadersIfNecessary(java.util.Map<java.lang.String,java.lang.Object> headers)
private java.lang.Object	convertHeaderValueIfNecessary(java.lang.Object value) Converts a header value to a String if the value type is unsupported by AMQP, also handling values nested inside Lists or Maps.
private java.lang.Object	convertLongString(com.rabbitmq.client.LongString longString, java.lang.String charset) Converts a LongString value to either a String or DataInputStream based on a length-driven threshold.
private java.lang.Object	convertLongStringIfNecessary(java.lang.Object value, java.lang.String charset) Converts a LongString value using convertLongString(LongString, String), also handling values nested in Lists or Maps.
com.rabbitmq.client.AMQP.BasicProperties	fromMessageProperties(MessageProperties source, java.lang.String charset)
MessageProperties	toMessageProperties(com.rabbitmq.client.AMQP.BasicProperties source, com.rabbitmq.client.Envelope envelope, java.lang.String charset)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultMessagePropertiesConverter

public DefaultMessagePropertiesConverter()

Method Detail

toMessageProperties

public MessageProperties toMessageProperties(com.rabbitmq.client.AMQP.BasicProperties source,
                                             com.rabbitmq.client.Envelope envelope,
                                             java.lang.String charset)

Specified by:

toMessageProperties in interface MessagePropertiesConverter

fromMessageProperties

public com.rabbitmq.client.AMQP.BasicProperties fromMessageProperties(MessageProperties source,
                                                                      java.lang.String charset)

Specified by:

fromMessageProperties in interface MessagePropertiesConverter

convertHeadersIfNecessary

private java.util.Map<java.lang.String,java.lang.Object> convertHeadersIfNecessary(java.util.Map<java.lang.String,java.lang.Object> headers)

convertHeaderValueIfNecessary

private java.lang.Object convertHeaderValueIfNecessary(java.lang.Object value)

Converts a header value to a String if the value type is unsupported by AMQP, also handling values nested inside Lists or Maps.

null values are passed through, although Rabbit client will throw an IllegalArgumentException.

convertLongString

private java.lang.Object convertLongString(com.rabbitmq.client.LongString longString,
                                           java.lang.String charset)

Converts a LongString value to either a String or DataInputStream based on a length-driven threshold. If the length is 1024 bytes or less, a String will be returned, otherwise a DataInputStream is returned.

convertLongStringIfNecessary

private java.lang.Object convertLongStringIfNecessary(java.lang.Object value,
                                                      java.lang.String charset)

Converts a LongString value using convertLongString(LongString, String), also handling values nested in Lists or Maps.