|
Spring Integration | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.integration.mapping.AbstractHeaderMapper<org.springframework.amqp.core.MessageProperties>
org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper
public class DefaultAmqpHeaderMapper
Default implementation of AmqpHeaderMapper.
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.
| Field Summary |
|---|
| Fields inherited from class org.springframework.integration.mapping.AbstractHeaderMapper |
|---|
logger, STANDARD_REPLY_HEADER_NAME_PATTERN, STANDARD_REQUEST_HEADER_NAME_PATTERN |
| Constructor Summary | |
|---|---|
DefaultAmqpHeaderMapper()
|
|
| Method Summary | |
|---|---|
protected java.util.Map<java.lang.String,java.lang.Object> |
extractStandardHeaders(org.springframework.amqp.core.MessageProperties amqpMessageProperties)
Extract "standard" headers from an AMQP MessageProperties instance. |
protected java.util.Map<java.lang.String,java.lang.Object> |
extractUserDefinedHeaders(org.springframework.amqp.core.MessageProperties amqpMessageProperties)
Extract user-defined headers from an AMQP MessageProperties instance. |
protected java.lang.String |
getStandardHeaderPrefix()
Returns the list of standard REPLY headers. |
protected java.util.List<java.lang.String> |
getStandardReplyHeaderNames()
Returns the list of standard REQUEST headers. |
protected java.util.List<java.lang.String> |
getStandardRequestHeaderNames()
Returns the PREFIX used by standard headers (if any) |
protected void |
populateStandardHeaders(java.util.Map<java.lang.String,java.lang.Object> headers,
org.springframework.amqp.core.MessageProperties amqpMessageProperties)
Maps headers from a Spring Integration MessageHeaders instance to the MessageProperties of an AMQP Message. |
protected void |
populateUserDefinedHeader(java.lang.String headerName,
java.lang.Object headerValue,
org.springframework.amqp.core.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 |
|---|
public DefaultAmqpHeaderMapper()
| Method Detail |
|---|
protected java.util.Map<java.lang.String,java.lang.Object> extractStandardHeaders(org.springframework.amqp.core.MessageProperties amqpMessageProperties)
extractStandardHeaders in class AbstractHeaderMapper<org.springframework.amqp.core.MessageProperties>protected java.util.Map<java.lang.String,java.lang.Object> extractUserDefinedHeaders(org.springframework.amqp.core.MessageProperties amqpMessageProperties)
extractUserDefinedHeaders in class AbstractHeaderMapper<org.springframework.amqp.core.MessageProperties>
protected void populateStandardHeaders(java.util.Map<java.lang.String,java.lang.Object> headers,
org.springframework.amqp.core.MessageProperties amqpMessageProperties)
populateStandardHeaders in class AbstractHeaderMapper<org.springframework.amqp.core.MessageProperties>
protected void populateUserDefinedHeader(java.lang.String headerName,
java.lang.Object headerValue,
org.springframework.amqp.core.MessageProperties amqpMessageProperties)
populateUserDefinedHeader in class AbstractHeaderMapper<org.springframework.amqp.core.MessageProperties>protected java.util.List<java.lang.String> getStandardRequestHeaderNames()
AbstractHeaderMapper
getStandardRequestHeaderNames in class AbstractHeaderMapper<org.springframework.amqp.core.MessageProperties>protected java.util.List<java.lang.String> getStandardReplyHeaderNames()
AbstractHeaderMapper
getStandardReplyHeaderNames in class AbstractHeaderMapper<org.springframework.amqp.core.MessageProperties>protected java.lang.String getStandardHeaderPrefix()
AbstractHeaderMapper
getStandardHeaderPrefix in class AbstractHeaderMapper<org.springframework.amqp.core.MessageProperties>
|
Spring Integration | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||