Package org.springframework.integration.mapping

Class AbstractHeaderMapper<T>

java.lang.Object

org.springframework.integration.mapping.AbstractHeaderMapper<T>

Type Parameters:

T - the target headers container type.

All Implemented Interfaces:

Aware, BeanClassLoaderAware, RequestReplyHeaderMapper<T>

Direct Known Subclasses:

DefaultAmqpHeaderMapper, DefaultSoapHeaderMapper, DefaultXmppHeaderMapper

public abstract class AbstractHeaderMapper<T>
extends Object
implements RequestReplyHeaderMapper<T>, BeanClassLoaderAware

Abstract base class for RequestReplyHeaderMapper implementations.

Since:

2.1

Author:

Mark Fisher, Oleg Zhurakousky, Stephane Nicoll, Gary Russell, Artem Bilan

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AbstractHeaderMapper.CompositeHeaderMatcher	A composite AbstractHeaderMapper.HeaderMatcher that matches if one of provided AbstractHeaderMapper.HeaderMatchers matches to the headerName.
protected static class	AbstractHeaderMapper.ContentBasedHeaderMatcher	A content-based AbstractHeaderMapper.HeaderMatcher that matches if the specified header is contained within a list of candidates.
static interface	AbstractHeaderMapper.HeaderMatcher	Strategy interface to determine if a given header name matches.
protected static class	AbstractHeaderMapper.PatternBasedHeaderMatcher	A pattern-based AbstractHeaderMapper.HeaderMatcher that matches if the specified header matches one of the specified simple patterns.
protected static class	AbstractHeaderMapper.PrefixBasedMatcher	A prefix-based AbstractHeaderMapper.HeaderMatcher that matches if the specified header starts with a configurable prefix.
protected static class	AbstractHeaderMapper.SinglePatternBasedHeaderMatcher	A pattern-based AbstractHeaderMapper.HeaderMatcher that matches if the specified header matches the specified simple pattern.

Field Summary

Fields

Modifier and Type	Field	Description
protected Log	logger
static String	NON_STANDARD_HEADER_NAME_PATTERN	A special pattern that matches any header that is not a standard header (i.e.
static String	STANDARD_REPLY_HEADER_NAME_PATTERN	A special pattern that only matches standard reply headers.
static String	STANDARD_REQUEST_HEADER_NAME_PATTERN	A special pattern that only matches standard request headers.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractHeaderMapper(String standardHeaderPrefix, Collection<String> requestHeaderNames, Collection<String> replyHeaderNames)	Create a new instance.

Method Summary

Modifier and Type	Method	Description
protected AbstractHeaderMapper.HeaderMatcher	createDefaultHeaderMatcher(String standardHeaderPrefix, Collection<String> headerNames)	Create the initial AbstractHeaderMapper.HeaderMatcher based on the specified headers and standard header prefix.
protected AbstractHeaderMapper.HeaderMatcher	createHeaderMatcher(Collection<String> patterns)	Create a AbstractHeaderMapper.HeaderMatcher that match if any of the specified patterns match.
protected String	createTargetPropertyName(String propertyName, boolean fromMessageHeaders)	Alter the specified propertyName if necessary.
protected abstract Map<String,Object>	extractStandardHeaders(T source)	Extract the standard headers from the specified source.
protected abstract Map<String,Object>	extractUserDefinedHeaders(T source)	Extract the user-defined headers from the specified source.
void	fromHeadersToReply(MessageHeaders headers, T target)	Map from the given MessageHeaders to the specified reply target.
void	fromHeadersToRequest(MessageHeaders headers, T target)	Map from the given MessageHeaders to the specified request target.
protected ClassLoader	getClassLoader()
protected <V> V	getHeaderIfAvailable(Map<String,Object> headers, String name, Class<V> type)
protected Collection<String>	getTransientHeaderNames()	Return the transient header names.
protected void	populateStandardHeaders(Map<String,Object> allHeaders, Map<String,Object> subset, T target)	Populate the specified standard headers to the specified source.
protected abstract void	populateStandardHeaders(Map<String,Object> headers, T target)	Populate the specified standard headers to the specified source.
protected abstract void	populateUserDefinedHeader(String headerName, Object headerValue, T target)	Populate the specified user-defined headers to the specified source.
void	setBeanClassLoader(ClassLoader classLoader)
void	setReplyHeaderNames(String... replyHeaderNames)	Provide the header names that should be mapped to a response from a MessageHeaders.
void	setRequestHeaderNames(String... requestHeaderNames)	Provide the header names that should be mapped from a request to a MessageHeaders.
Map<String,Object>	toHeadersFromReply(T source)	Map from the given reply object to abstracted MessageHeaders.
Map<String,Object>	toHeadersFromRequest(T source)	Map from the given request object to abstracted MessageHeaders.

Methods inherited from class java.lang.Object

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

Field Details

STANDARD_REQUEST_HEADER_NAME_PATTERN

public static final String STANDARD_REQUEST_HEADER_NAME_PATTERN

A special pattern that only matches standard request headers.

See Also:

Constant Field Values

STANDARD_REPLY_HEADER_NAME_PATTERN

public static final String STANDARD_REPLY_HEADER_NAME_PATTERN

A special pattern that only matches standard reply headers.

See Also:

Constant Field Values

NON_STANDARD_HEADER_NAME_PATTERN

public static final String NON_STANDARD_HEADER_NAME_PATTERN

A special pattern that matches any header that is not a standard header (i.e. any header that does not start with the configured standard header prefix)

See Also:

Constant Field Values

logger

protected final Log logger

Constructor Details

AbstractHeaderMapper

protected AbstractHeaderMapper(String standardHeaderPrefix, Collection<String> requestHeaderNames, Collection<String> replyHeaderNames)

Create a new instance.

Parameters:

standardHeaderPrefix - the header prefix that identifies standard header. Such prefix helps to differentiate user-defined headers from standard headers. If set, user-defined headers are also mapped by default

requestHeaderNames - the header names that should be mapped from a request to MessageHeaders

replyHeaderNames - the header names that should be mapped to a response from MessageHeaders

Method Details

setBeanClassLoader

public void setBeanClassLoader(ClassLoader classLoader)

Specified by:

setBeanClassLoader in interface BeanClassLoaderAware

getClassLoader

protected ClassLoader getClassLoader()

setRequestHeaderNames

public void setRequestHeaderNames(String... requestHeaderNames)

Provide the header names that should be mapped from a request to a MessageHeaders.

The values can also contain simple wildcard patterns (e.g. "foo*" or "*foo") to be matched.

Parameters:

requestHeaderNames - The request header names.

setReplyHeaderNames

public void setReplyHeaderNames(String... replyHeaderNames)

Provide the header names that should be mapped to a response from a MessageHeaders.

The values can also contain simple wildcard patterns (e.g. "foo*" or "*foo") to be matched.

Parameters:

replyHeaderNames - The reply header names.

createDefaultHeaderMatcher

protected AbstractHeaderMapper.HeaderMatcher createDefaultHeaderMatcher(String standardHeaderPrefix, Collection<String> headerNames)

Create the initial AbstractHeaderMapper.HeaderMatcher based on the specified headers and standard header prefix.

Parameters:

standardHeaderPrefix - the prefix for standard headers.

headerNames - the collection of header names to map.

Returns:

the default AbstractHeaderMapper.HeaderMatcher instance.

createHeaderMatcher

protected AbstractHeaderMapper.HeaderMatcher createHeaderMatcher(Collection<String> patterns)

Create a AbstractHeaderMapper.HeaderMatcher that match if any of the specified patterns match. The pattern can be a header name, a wildcard pattern such as foo*, *foo, or within*foo.

Special patterns are also recognized: STANDARD_REQUEST_HEADER_NAME_PATTERN, STANDARD_REQUEST_HEADER_NAME_PATTERN and NON_STANDARD_HEADER_NAME_PATTERN.

Parameters:

patterns - the patterns to apply

Returns:

a header mapper that match if any of the specified patters match

fromHeadersToRequest

public void fromHeadersToRequest(MessageHeaders headers, T target)

Description copied from interface: RequestReplyHeaderMapper

Map from the given MessageHeaders to the specified request target.

Specified by:

fromHeadersToRequest in interface RequestReplyHeaderMapper<T>

Parameters:

headers - the abstracted MessageHeaders

target - the native target request

fromHeadersToReply

public void fromHeadersToReply(MessageHeaders headers, T target)

Description copied from interface: RequestReplyHeaderMapper

Map from the given MessageHeaders to the specified reply target.

Specified by:

fromHeadersToReply in interface RequestReplyHeaderMapper<T>

Parameters:

headers - the abstracted MessageHeaders

target - the native target reply

toHeadersFromRequest

public Map<String,Object> toHeadersFromRequest(T source)

Description copied from interface: RequestReplyHeaderMapper

Map from the given request object to abstracted MessageHeaders.

Specified by:

toHeadersFromRequest in interface RequestReplyHeaderMapper<T>

Parameters:

source - the native target request

Returns:

the abstracted MessageHeaders

toHeadersFromReply

public Map<String,Object> toHeadersFromReply(T source)

Description copied from interface: RequestReplyHeaderMapper

Map from the given reply object to abstracted MessageHeaders.

Specified by:

toHeadersFromReply in interface RequestReplyHeaderMapper<T>

Parameters:

source - the native target reply

Returns:

the abstracted MessageHeaders

getHeaderIfAvailable

@Nullable protected <V> V getHeaderIfAvailable(Map<String,Object> headers, String name, Class<V> type)

createTargetPropertyName

protected String createTargetPropertyName(String propertyName, boolean fromMessageHeaders)

Alter the specified propertyName if necessary. By default, the original propertyName is returned.

Parameters:

propertyName - the original name of the property.

fromMessageHeaders - specify if the property originates from a MessageHeaders instance (true) or from the type managed by this mapper (false).

Returns:

the property name for mapping.

getTransientHeaderNames

protected Collection<String> getTransientHeaderNames()

Return the transient header names. Transient headers are never mapped.

Returns:

the names of headers to be skipped from mapping.

extractStandardHeaders

protected abstract Map<String,Object> extractStandardHeaders(T source)

Extract the standard headers from the specified source.

Parameters:

source - the source object to extract standard headers.

Returns:

the map of headers to be mapped.

extractUserDefinedHeaders

protected abstract Map<String,Object> extractUserDefinedHeaders(T source)

Extract the user-defined headers from the specified source.

Parameters:

source - the source object to extract user defined headers.

Returns:

the map of headers to be mapped.

populateStandardHeaders

protected abstract void populateStandardHeaders(Map<String,Object> headers, T target)

Populate the specified standard headers to the specified source.

Parameters:

headers - the map of standard headers to be populated.

target - the target object to populate headers.

populateStandardHeaders

protected void populateStandardHeaders(@Nullable Map<String,Object> allHeaders, Map<String,Object> subset, T target)

Populate the specified standard headers to the specified source. If not implemented, calls populateStandardHeaders(Map, Object).

Parameters:

allHeaders - all headers including transient.

subset - the map of standard headers to be populated.

target - the target object to populate headers.

Since:

5.1

populateUserDefinedHeader

protected abstract void populateUserDefinedHeader(String headerName, Object headerValue, T target)

Populate the specified user-defined headers to the specified source.

Parameters:

headerName - the user defined header name to be populated.

headerValue - the user defined header value to be populated.

target - the target object to populate headers.