org.springframework.amqp.support.converter

Class JsonMessageConverter

java.lang.Object

org.springframework.amqp.support.converter.AbstractMessageConverter

org.springframework.amqp.support.converter.AbstractJsonMessageConverter

org.springframework.amqp.support.converter.JsonMessageConverter

All Implemented Interfaces:

MessageConverter

public class JsonMessageConverter
extends AbstractJsonMessageConverter

JSON converter that uses the Jackson Json library.

Field Summary

Fields

Modifier and Type	Field and Description
private JavaTypeMapper	javaTypeMapper
private org.codehaus.jackson.map.ObjectMapper	jsonObjectMapper
private static org.apache.commons.logging.Log	log

Fields inherited from class org.springframework.amqp.support.converter.AbstractJsonMessageConverter

DEFAULT_CHARSET

Constructor Summary

Constructors

Constructor and Description
JsonMessageConverter()

Method Summary

Modifier and Type	Method and Description
private java.lang.Object	convertBytesToObject(byte[] body, java.lang.String encoding, java.lang.Class<?> targetClass)
private java.lang.Object	convertBytesToObject(byte[] body, java.lang.String encoding, org.codehaus.jackson.type.JavaType targetJavaType)
protected Message	createMessage(java.lang.Object objectToConvert, MessageProperties messageProperties) Crate a message from the payload object and message properties provided.
java.lang.Object	fromMessage(Message message) Convert from a Message to a Java object.
JavaTypeMapper	getJavaTypeMapper()
protected void	initializeJsonObjectMapper() Subclass and override to customize.
void	setJavaTypeMapper(JavaTypeMapper javaTypeMapper)
void	setJsonObjectMapper(org.codehaus.jackson.map.ObjectMapper jsonObjectMapper) The ObjectMapper to use instead of using the default.

Methods inherited from class org.springframework.amqp.support.converter.AbstractJsonMessageConverter

getClassMapper, getDefaultCharset, setClassMapper, setDefaultCharset

Methods inherited from class org.springframework.amqp.support.converter.AbstractMessageConverter

isCreateMessageIds, setCreateMessageIds, toMessage

Methods inherited from class java.lang.Object

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

Field Detail

log

private static org.apache.commons.logging.Log log

jsonObjectMapper

private org.codehaus.jackson.map.ObjectMapper jsonObjectMapper

javaTypeMapper

private JavaTypeMapper javaTypeMapper

Constructor Detail

JsonMessageConverter

public JsonMessageConverter()

Method Detail

getJavaTypeMapper

public JavaTypeMapper getJavaTypeMapper()

setJavaTypeMapper

public void setJavaTypeMapper(JavaTypeMapper javaTypeMapper)

setJsonObjectMapper

public void setJsonObjectMapper(org.codehaus.jackson.map.ObjectMapper jsonObjectMapper)

The ObjectMapper to use instead of using the default. An alternative to injecting a mapper is to extend this class and override initializeJsonObjectMapper().

Parameters:

jsonObjectMapper - the object mapper to set

initializeJsonObjectMapper

protected void initializeJsonObjectMapper()

Subclass and override to customize.

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

Specified by:

fromMessage in class AbstractMessageConverter

Parameters:

message - the message to convert

Returns:

the converted Java object

Throws:

MessageConversionException - in case of conversion failure

convertBytesToObject

private java.lang.Object convertBytesToObject(byte[] body,
                                              java.lang.String encoding,
                                              org.codehaus.jackson.type.JavaType targetJavaType)
                                       throws org.codehaus.jackson.JsonParseException,
                                              org.codehaus.jackson.map.JsonMappingException,
                                              java.io.IOException

Throws:

org.codehaus.jackson.JsonParseException

org.codehaus.jackson.map.JsonMappingException

java.io.IOException

convertBytesToObject

private java.lang.Object convertBytesToObject(byte[] body,
                                              java.lang.String encoding,
                                              java.lang.Class<?> targetClass)
                                       throws org.codehaus.jackson.JsonParseException,
                                              org.codehaus.jackson.map.JsonMappingException,
                                              java.io.IOException

Throws:

org.codehaus.jackson.JsonParseException

org.codehaus.jackson.map.JsonMappingException

java.io.IOException

createMessage

protected Message createMessage(java.lang.Object objectToConvert,
                                MessageProperties messageProperties)
                         throws MessageConversionException

Description copied from class: AbstractMessageConverter

Crate a message from the payload object and message properties provided. The message id will be added to the properties if necessary later.

Specified by:

createMessage in class AbstractMessageConverter

Parameters:

objectToConvert - the payload

messageProperties - the message properties (headers)

Returns:

a message

Throws:

MessageConversionException