org.springframework.amqp.rabbit.support

Class DefaultMessagePropertiesConverter

java.lang.Object

org.springframework.amqp.rabbit.support.DefaultMessagePropertiesConverter

All Implemented Interfaces:

MessagePropertiesConverter

public class DefaultMessagePropertiesConverter
extends Object
implements MessagePropertiesConverter

Default implementation of the MessagePropertiesConverter strategy.

Since:

1.0

Author:

Mark Fisher, Gary Russell, Soeren Unruh

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DefaultMessagePropertiesConverter.CorrelationIdPolicy Deprecated.

Constructor Summary

Constructors

Constructor and Description
DefaultMessagePropertiesConverter() Construct an instance where LongStrings will be returned unconverted when longer than 1024 bytes.
DefaultMessagePropertiesConverter(int longStringLimit) Construct an instance where LongStrings will be returned unconverted when longer than this limit.
DefaultMessagePropertiesConverter(int longStringLimit, boolean convertLongLongStrings) Construct an instance where LongStrings will be returned unconverted or as a DataInputStream when longer than this limit.

Method Summary

Modifier and Type	Method and Description
com.rabbitmq.client.AMQP.BasicProperties	fromMessageProperties(MessageProperties source, String charset)
void	setCorrelationIdAsString(DefaultMessagePropertiesConverter.CorrelationIdPolicy correlationIPolicy) Deprecated. - the byte[] version of correlation id will be removed in 2.0
void	setCorrelationIdPolicy(DefaultMessagePropertiesConverter.CorrelationIdPolicy correlationIPolicy) Deprecated. - the byte[] version of correlation id will be removed in 2.0
MessageProperties	toMessageProperties(com.rabbitmq.client.AMQP.BasicProperties source, com.rabbitmq.client.Envelope envelope, 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()

Construct an instance where LongStrings will be returned unconverted when longer than 1024 bytes.

DefaultMessagePropertiesConverter

public DefaultMessagePropertiesConverter(int longStringLimit)

Construct an instance where LongStrings will be returned unconverted when longer than this limit.

Parameters:

longStringLimit - the limit.

Since:

1.4.4

DefaultMessagePropertiesConverter

public DefaultMessagePropertiesConverter(int longStringLimit,
                                         boolean convertLongLongStrings)

Construct an instance where LongStrings will be returned unconverted or as a DataInputStream when longer than this limit. Use this constructor with 'true' to restore pre-1.6 behavior.

Parameters:

longStringLimit - the limit.

convertLongLongStrings - LongString when false, DataInputStream when true.

Since:

1.6

Method Detail

setCorrelationIdAsString

@Deprecated
public void setCorrelationIdAsString(DefaultMessagePropertiesConverter.CorrelationIdPolicy correlationIPolicy)

Deprecated. - the byte[] version of correlation id will be removed in 2.0

Parameters:

correlationIPolicy - true to use.

See Also:

setCorrelationIdPolicy(CorrelationIdPolicy)

setCorrelationIdPolicy

@Deprecated
public void setCorrelationIdPolicy(DefaultMessagePropertiesConverter.CorrelationIdPolicy correlationIPolicy)

Deprecated. - the byte[] version of correlation id will be removed in 2.0

For inbound, determine whether correlationId, correlationIdString or both are populated. For outbound, determine whether correlationIdString or correlationId is used when mapping; if CorrelationIdPolicy.BOTH is set for outbound, String takes priority and we fallback to bytes. Default CorrelationIdPolicy.BYTES.

Parameters:

correlationIPolicy - true to use.

toMessageProperties

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

Specified by:

toMessageProperties in interface MessagePropertiesConverter

fromMessageProperties

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

Specified by:

fromMessageProperties in interface MessagePropertiesConverter