Package com.alibaba.cloud.stream.binder.rocketmq.support

Class JacksonRocketMQHeaderMapper

java.lang.Object

com.alibaba.cloud.stream.binder.rocketmq.support.AbstractRocketMQHeaderMapper

com.alibaba.cloud.stream.binder.rocketmq.support.JacksonRocketMQHeaderMapper

All Implemented Interfaces:

RocketMQHeaderMapper

public class JacksonRocketMQHeaderMapper
extends AbstractRocketMQHeaderMapper

jackson header mapper for RocketMQ. Header types are added to a special header JSON_TYPES.

Since:

2.1.1.RELEASE

Author:

caotc

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JacksonRocketMQHeaderMapper.NonTrustedHeaderType	Represents a header that could not be decoded due to an untrusted type.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	JSON_TYPES	Header name for java types of other headers.

Constructor Summary

Constructors

Constructor	Description
JacksonRocketMQHeaderMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
JacksonRocketMQHeaderMapper(Charset charset, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
void	addTrustedPackages(String... packagesToTrust)
void	addTrustedPackages(Collection<String> packagesToTrust)	Add packages to the trusted packages list (default java.util, java.lang) used when constructing objects from JSON.
Map<String,String>	fromHeaders(org.springframework.messaging.MessageHeaders headers)	Map from the given MessageHeaders to the specified target message.
com.fasterxml.jackson.databind.ObjectMapper	getObjectMapper()
Set<String>	getTrustedPackages()
org.springframework.messaging.MessageHeaders	toHeaders(Map<String,String> source)	Map from the given target message to abstracted MessageHeaders.
protected boolean	trusted(String requestedType)

Methods inherited from class com.alibaba.cloud.stream.binder.rocketmq.support.AbstractRocketMQHeaderMapper

getCharset, matches, setCharset

Methods inherited from class java.lang.Object

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

Field Details

JSON_TYPES

public static final String JSON_TYPES

Header name for java types of other headers.

See Also:

• Constant Field Values

Constructor Details

JacksonRocketMQHeaderMapper

public JacksonRocketMQHeaderMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

JacksonRocketMQHeaderMapper

public JacksonRocketMQHeaderMapper(Charset charset,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Details

fromHeaders

public Map<String,String> fromHeaders(org.springframework.messaging.MessageHeaders headers)

Description copied from interface: RocketMQHeaderMapper

Map from the given MessageHeaders to the specified target message.

Parameters:

headers - the abstracted MessageHeaders.

Returns:

the native target message.

toHeaders

public org.springframework.messaging.MessageHeaders toHeaders(Map<String,String> source)

Description copied from interface: RocketMQHeaderMapper

Map from the given target message to abstracted MessageHeaders.

Parameters:

source - the native target message.

Returns:

the target headers.

addTrustedPackages

public void addTrustedPackages(String... packagesToTrust)

Parameters:

packagesToTrust - the packages to trust.

See Also:

• addTrustedPackages(Collection)

addTrustedPackages

public void addTrustedPackages(Collection<String> packagesToTrust)

Add packages to the trusted packages list (default java.util, java.lang) used when constructing objects from JSON. If any of the supplied packages is "*", all packages are trusted. If a class for a non-trusted package is encountered, the header is returned to the application with value of type JacksonRocketMQHeaderMapper.NonTrustedHeaderType.

Parameters:

packagesToTrust - the packages to trust.

getTrustedPackages

public Set<String> getTrustedPackages()

getObjectMapper

public com.fasterxml.jackson.databind.ObjectMapper getObjectMapper()

trusted

protected boolean trusted(String requestedType)