org.springframework.amqp.support.converter

Class Jackson2JsonMessageConverter

java.lang.Object

org.springframework.amqp.support.converter.AbstractMessageConverter

org.springframework.amqp.support.converter.AbstractJsonMessageConverter

org.springframework.amqp.support.converter.Jackson2JsonMessageConverter

All Implemented Interfaces:

MessageConverter

public class Jackson2JsonMessageConverter
extends AbstractJsonMessageConverter

JSON converter that uses the Jackson 2 Json library.

Field Summary

Fields

Modifier and Type	Field and Description
private Jackson2JavaTypeMapper	javaTypeMapper
private com.fasterxml.jackson.databind.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
Jackson2JsonMessageConverter()

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, com.fasterxml.jackson.databind.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.
Jackson2JavaTypeMapper	getJavaTypeMapper()
protected void	initializeJsonObjectMapper() Subclass and override to customize.
void	setJavaTypeMapper(Jackson2JavaTypeMapper javaTypeMapper)
void	setJsonObjectMapper(com.fasterxml.jackson.databind.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 com.fasterxml.jackson.databind.ObjectMapper jsonObjectMapper

javaTypeMapper

private Jackson2JavaTypeMapper javaTypeMapper

Constructor Detail

Jackson2JsonMessageConverter

public Jackson2JsonMessageConverter()

Method Detail

getJavaTypeMapper

public Jackson2JavaTypeMapper getJavaTypeMapper()

setJavaTypeMapper

public void setJavaTypeMapper(Jackson2JavaTypeMapper javaTypeMapper)

setJsonObjectMapper

public void setJsonObjectMapper(com.fasterxml.jackson.databind.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,
                                              com.fasterxml.jackson.databind.JavaType targetJavaType)
                                       throws com.fasterxml.jackson.core.JsonParseException,
                                              com.fasterxml.jackson.databind.JsonMappingException,
                                              java.io.IOException

Throws:

com.fasterxml.jackson.core.JsonParseException

com.fasterxml.jackson.databind.JsonMappingException

java.io.IOException

convertBytesToObject

private java.lang.Object convertBytesToObject(byte[] body,
                                              java.lang.String encoding,
                                              java.lang.Class<?> targetClass)
                                       throws com.fasterxml.jackson.core.JsonParseException,
                                              com.fasterxml.jackson.databind.JsonMappingException,
                                              java.io.IOException

Throws:

com.fasterxml.jackson.core.JsonParseException

com.fasterxml.jackson.databind.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