Class AbstractJackson2MessageConverter
- java.lang.Object
-
- org.springframework.amqp.support.converter.AbstractMessageConverter
-
- org.springframework.amqp.support.converter.AbstractJackson2MessageConverter
-
- All Implemented Interfaces:
MessageConverter
,SmartMessageConverter
,Aware
,BeanClassLoaderAware
- Direct Known Subclasses:
Jackson2JsonMessageConverter
,Jackson2XmlMessageConverter
public abstract class AbstractJackson2MessageConverter extends AbstractMessageConverter implements BeanClassLoaderAware, SmartMessageConverter
Abstract Jackson2 message converter.- Since:
- 2.1
- Author:
- Mark Pollack, James Carr, Dave Syer, Sam Nelson, Andreas Asplund, Artem Bilan, Mohammad Hewedy, Gary Russell
-
-
Field Summary
Fields Modifier and Type Field Description static java.nio.charset.Charset
DEFAULT_CHARSET
The charset used when convertingString
to/frombyte[]
.protected Log
log
protected com.fasterxml.jackson.databind.ObjectMapper
objectMapper
-
Constructor Summary
Constructors Modifier Constructor Description protected
AbstractJackson2MessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper, MimeType contentType, java.lang.String... trustedPackages)
Construct with the providedObjectMapper
instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Message
createMessage(java.lang.Object objectToConvert, MessageProperties messageProperties)
Crate a message from the payload object and message properties provided.protected Message
createMessage(java.lang.Object objectToConvert, MessageProperties messageProperties, java.lang.reflect.Type genericType)
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.java.lang.Object
fromMessage(Message message, java.lang.Object conversionHint)
A variant ofMessageConverter.fromMessage(Message)
which takes an extra conversion context as an argument.protected java.lang.ClassLoader
getClassLoader()
ClassMapper
getClassMapper()
java.lang.String
getDefaultCharset()
Jackson2JavaTypeMapper
getJavaTypeMapper()
protected MimeType
getSupportedContentType()
Get the supported content type; only the subtype is checked when decoding, e.g.Jackson2JavaTypeMapper.TypePrecedence
getTypePrecedence()
Return the type precedence.boolean
isTypeMapperSet()
Whether or not an explicit java type mapper has been provided.protected boolean
isUseProjectionForInterfaces()
void
setAlwaysConvertToInferredType(boolean alwaysAttemptConversion)
When false (default), fall back to type id headers if the type (or contents of a container type) is abstract.void
setAssumeSupportedContentType(boolean assumeSupportedContentType)
By default the supported content type is assumed when there is no contentType property or it is set to the default ('application/octet-stream').void
setBeanClassLoader(java.lang.ClassLoader classLoader)
void
setClassMapper(ClassMapper classMapper)
void
setDefaultCharset(java.lang.String defaultCharset)
Specify the default charset to use when converting to or from text-based Message body content.void
setJavaTypeMapper(Jackson2JavaTypeMapper javaTypeMapper)
void
setNullAsOptionalEmpty(boolean nullAsOptionalEmpty)
When true, if jackson decodes the body asnull
convert toOptional.empty()
instead of returning the original body.void
setSupportedContentType(MimeType supportedContentType)
Set the supported content type; only the subtype is checked when decoding, e.g.void
setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence typePrecedence)
Set the precedence for evaluating type information in message properties.void
setUseProjectionForInterfaces(boolean useProjectionForInterfaces)
Set to true to use Spring Data projection to create the object if the inferred parameter type is an interface.-
Methods inherited from class org.springframework.amqp.support.converter.AbstractMessageConverter
isCreateMessageIds, setCreateMessageIds, toMessage, toMessage
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.springframework.amqp.support.converter.MessageConverter
toMessage, toMessage
-
-
-
-
Field Detail
-
log
protected final Log log
-
DEFAULT_CHARSET
public static final java.nio.charset.Charset DEFAULT_CHARSET
The charset used when convertingString
to/frombyte[]
.
-
objectMapper
protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper
-
-
Constructor Detail
-
AbstractJackson2MessageConverter
protected AbstractJackson2MessageConverter(com.fasterxml.jackson.databind.ObjectMapper objectMapper, MimeType contentType, java.lang.String... trustedPackages)
Construct with the providedObjectMapper
instance.- Parameters:
objectMapper
- theObjectMapper
to use.contentType
- the supported content type; only the subtype is checked when decoding, e.g. */json, */xml. If this contains a charset parameter, when encoding, the contentType header will not be set, when decoding, the raw bytes are passed to Jackson which can dynamically determine the encoding; otherwise the contentEncoding or default charset is used.trustedPackages
- the trusted Java packages for deserialization- See Also:
DefaultJackson2JavaTypeMapper.setTrustedPackages(String...)
-
-
Method Detail
-
getSupportedContentType
protected MimeType getSupportedContentType()
Get the supported content type; only the subtype is checked when decoding, e.g. */json, */xml. If this contains a charset parameter, when encoding, the contentType header will not be set, when decoding, the raw bytes are passed to Jackson which can dynamically determine the encoding; otherwise the contentEncoding or default charset is used.- Returns:
- the supportedContentType
- Since:
- 2.4.3
-
setSupportedContentType
public void setSupportedContentType(MimeType supportedContentType)
Set the supported content type; only the subtype is checked when decoding, e.g. */json, */xml. If this contains a charset parameter, when encoding, the contentType header will not be set, when decoding, the raw bytes are passed to Jackson which can dynamically determine the encoding; otherwise the contentEncoding or default charset is used.- Parameters:
supportedContentType
- the supportedContentType to set.- Since:
- 2.4.3
-
setNullAsOptionalEmpty
public void setNullAsOptionalEmpty(boolean nullAsOptionalEmpty)
When true, if jackson decodes the body asnull
convert toOptional.empty()
instead of returning the original body. Default false.- Parameters:
nullAsOptionalEmpty
- true to return empty.- Since:
- 2.4.7
-
getClassMapper
@Nullable public ClassMapper getClassMapper()
-
setClassMapper
public void setClassMapper(ClassMapper classMapper)
-
setDefaultCharset
public void setDefaultCharset(@Nullable java.lang.String defaultCharset)
Specify the default charset to use when converting to or from text-based Message body content. If not specified, the charset will be "UTF-8".- Parameters:
defaultCharset
- The default charset.
-
getDefaultCharset
public java.lang.String getDefaultCharset()
-
setBeanClassLoader
public void setBeanClassLoader(java.lang.ClassLoader classLoader)
- Specified by:
setBeanClassLoader
in interfaceBeanClassLoaderAware
-
getClassLoader
protected java.lang.ClassLoader getClassLoader()
-
getJavaTypeMapper
public Jackson2JavaTypeMapper getJavaTypeMapper()
-
isTypeMapperSet
public boolean isTypeMapperSet()
Whether or not an explicit java type mapper has been provided.- Returns:
- false if the default type mapper is being used.
- Since:
- 2.2
- See Also:
setJavaTypeMapper(Jackson2JavaTypeMapper)
-
setJavaTypeMapper
public void setJavaTypeMapper(Jackson2JavaTypeMapper javaTypeMapper)
-
getTypePrecedence
public Jackson2JavaTypeMapper.TypePrecedence getTypePrecedence()
Return the type precedence.- Returns:
- the precedence.
- See Also:
setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence)
-
setTypePrecedence
public void setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence typePrecedence)
Set the precedence for evaluating type information in message properties. When using@RabbitListener
at the method level, the framework attempts to determine the target type for payload conversion from the method signature. If so, this type is provided in theinferredArgumentType
message property.By default, if the type is concrete (not abstract, not an interface), this will be used ahead of type information provided in the
__TypeId__
and associated headers provided by the sender.If you wish to force the use of the
__TypeId__
and associated headers (such as when the actual type is a subclass of the method argument type), set the precedence toJackson2JavaTypeMapper.TypePrecedence.TYPE_ID
.- Parameters:
typePrecedence
- the precedence.- See Also:
DefaultJackson2JavaTypeMapper.setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence)
-
setAlwaysConvertToInferredType
public void setAlwaysConvertToInferredType(boolean alwaysAttemptConversion)
When false (default), fall back to type id headers if the type (or contents of a container type) is abstract. Set to true if conversion should always be attempted - perhaps because a custom deserializer has been configured on theObjectMapper
. If the attempt fails, fall back to headers.- Parameters:
alwaysAttemptConversion
- true to attempt.- Since:
- 2.2.8
-
isUseProjectionForInterfaces
protected boolean isUseProjectionForInterfaces()
-
setUseProjectionForInterfaces
public void setUseProjectionForInterfaces(boolean useProjectionForInterfaces)
Set to true to use Spring Data projection to create the object if the inferred parameter type is an interface.- Parameters:
useProjectionForInterfaces
- true to use projection.- Since:
- 2.2
-
setAssumeSupportedContentType
public void setAssumeSupportedContentType(boolean assumeSupportedContentType)
By default the supported content type is assumed when there is no contentType property or it is set to the default ('application/octet-stream'). Set to 'false' to revert to the previous behavior of returning an unconverted 'byte[]' when this condition exists.- Parameters:
assumeSupportedContentType
- set false to not assume the content type is supported.- Since:
- 2.2
-
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 interfaceMessageConverter
- Parameters:
message
- the message to convert- Returns:
- the converted Java object
- Throws:
MessageConversionException
- in case of conversion failure
-
fromMessage
public java.lang.Object fromMessage(Message message, @Nullable java.lang.Object conversionHint) throws MessageConversionException
A variant ofMessageConverter.fromMessage(Message)
which takes an extra conversion context as an argument.- Specified by:
fromMessage
in interfaceSmartMessageConverter
- Parameters:
conversionHint
- The conversionHint must be aParameterizedTypeReference
.message
- the input message.- Returns:
- the result of the conversion, or
null
if the converter cannot perform the conversion. - Throws:
MessageConversionException
- if the conversion fails.- See Also:
MessageConverter.fromMessage(Message)
-
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 classAbstractMessageConverter
- Parameters:
objectToConvert
- the payload.messageProperties
- the message properties (headers).- Returns:
- a message.
- Throws:
MessageConversionException
-
createMessage
protected Message createMessage(java.lang.Object objectToConvert, MessageProperties messageProperties, @Nullable java.lang.reflect.Type genericType) 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.- Overrides:
createMessage
in classAbstractMessageConverter
- Parameters:
objectToConvert
- the payloadmessageProperties
- the message properties (headers)genericType
- the type to convert from - used to populate type headers.- Returns:
- a message
- Throws:
MessageConversionException
-
-