org.springframework.integration.amqp.support

Class DefaultAmqpHeaderMapper

java.lang.Object

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

org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper

All Implemented Interfaces:

AmqpHeaderMapper, RequestReplyHeaderMapper<MessageProperties>

public class DefaultAmqpHeaderMapper
extends AbstractHeaderMapper<MessageProperties>
implements AmqpHeaderMapper

Default implementation of AmqpHeaderMapper.

By default this implementation will only copy AMQP properties (e.g. contentType) to and from Spring Integration MessageHeaders. Any user-defined headers within the AMQP MessageProperties will NOT be copied to or from an AMQP Message unless explicitly identified via 'requestHeaderNames' and/or 'replyHeaderNames' (see AbstractHeaderMapper.setRequestHeaderNames(String[]) and AbstractHeaderMapper.setReplyHeaderNames(String[])} as well as 'mapped-request-headers' and 'mapped-reply-headers' attributes of the AMQP adapters). If you need to copy all user-defined headers simply use wild-card character '*'.

Constants for the AMQP header keys are defined in AmqpHeaders.

Since:

2.1

Author:

Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.mapping.AbstractHeaderMapper

logger, STANDARD_REPLY_HEADER_NAME_PATTERN, STANDARD_REQUEST_HEADER_NAME_PATTERN

Constructor Summary

Constructors

Constructor and Description
DefaultAmqpHeaderMapper()

Method Summary

Methods

Modifier and Type	Method and Description
protected Map<String,Object>	extractStandardHeaders(MessageProperties amqpMessageProperties) Extract "standard" headers from an AMQP MessageProperties instance.
protected Map<String,Object>	extractUserDefinedHeaders(MessageProperties amqpMessageProperties) Extract user-defined headers from an AMQP MessageProperties instance.
protected String	getStandardHeaderPrefix()
protected List<String>	getStandardReplyHeaderNames()
protected List<String>	getStandardRequestHeaderNames()
protected void	populateStandardHeaders(Map<String,Object> headers, MessageProperties amqpMessageProperties) Maps headers from a Spring Integration MessageHeaders instance to the MessageProperties of an AMQP Message.
protected void	populateUserDefinedHeader(String headerName, Object headerValue, MessageProperties amqpMessageProperties)

Methods inherited from class org.springframework.integration.mapping.AbstractHeaderMapper

fromHeadersToReply, fromHeadersToRequest, getHeaderIfAvailable, setReplyHeaderNames, setRequestHeaderNames, setUserDefinedHeaderPrefix, toHeadersFromReply, toHeadersFromRequest

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.mapping.RequestReplyHeaderMapper

fromHeadersToReply, fromHeadersToRequest, toHeadersFromReply, toHeadersFromRequest

Constructor Detail

DefaultAmqpHeaderMapper

public DefaultAmqpHeaderMapper()

Method Detail

extractStandardHeaders

protected Map<String,Object> extractStandardHeaders(MessageProperties amqpMessageProperties)

Extract "standard" headers from an AMQP MessageProperties instance.

Specified by:

extractStandardHeaders in class AbstractHeaderMapper<MessageProperties>

extractUserDefinedHeaders

protected Map<String,Object> extractUserDefinedHeaders(MessageProperties amqpMessageProperties)

Extract user-defined headers from an AMQP MessageProperties instance.

Specified by:

extractUserDefinedHeaders in class AbstractHeaderMapper<MessageProperties>

populateStandardHeaders

protected void populateStandardHeaders(Map<String,Object> headers,
                           MessageProperties amqpMessageProperties)

Maps headers from a Spring Integration MessageHeaders instance to the MessageProperties of an AMQP Message.

Specified by:

populateStandardHeaders in class AbstractHeaderMapper<MessageProperties>

populateUserDefinedHeader

protected void populateUserDefinedHeader(String headerName,
                             Object headerValue,
                             MessageProperties amqpMessageProperties)

Specified by:

populateUserDefinedHeader in class AbstractHeaderMapper<MessageProperties>

getStandardRequestHeaderNames

protected List<String> getStandardRequestHeaderNames()

Overrides:

getStandardRequestHeaderNames in class AbstractHeaderMapper<MessageProperties>

Returns:

The PREFIX used by standard headers (if any)

getStandardReplyHeaderNames

protected List<String> getStandardReplyHeaderNames()

Overrides:

getStandardReplyHeaderNames in class AbstractHeaderMapper<MessageProperties>

Returns:

The list of standard REQUEST headers. Implementation provided by a subclass

getStandardHeaderPrefix

protected String getStandardHeaderPrefix()

Specified by:

getStandardHeaderPrefix in class AbstractHeaderMapper<MessageProperties>

Returns:

The list of standard REPLY headers. Implementation provided by a subclass