Package org.springframework.amqp.support

Class AmqpMessageHeaderAccessor

java.lang.Object

org.springframework.messaging.support.MessageHeaderAccessor

org.springframework.messaging.support.NativeMessageHeaderAccessor

org.springframework.amqp.support.AmqpMessageHeaderAccessor

public class AmqpMessageHeaderAccessor
extends NativeMessageHeaderAccessor

A MessageHeaderAccessor implementation giving access to AMQP-specific headers.

Since:

1.4

Author:

Stephane Nicoll, Gary Russell

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	PRIORITY

Fields inherited from class org.springframework.messaging.support.NativeMessageHeaderAccessor

NATIVE_HEADERS

Fields inherited from class org.springframework.messaging.support.MessageHeaderAccessor

DEFAULT_CHARSET

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AmqpMessageHeaderAccessor(java.util.Map<java.lang.String,java.util.List<java.lang.String>> nativeHeaders)
protected	AmqpMessageHeaderAccessor(Message<?> message)

Method Summary

Modifier and Type	Method	Description
java.lang.String	getAppId()
java.lang.String	getClusterId()
java.lang.String	getConsumerQueue()
java.lang.String	getConsumerTag()
java.lang.String	getContentEncoding()
java.lang.Long	getContentLength()
MimeType	getContentType()
java.lang.String	getCorrelationId()
MessageDeliveryMode	getDeliveryMode()
java.lang.Long	getDeliveryTag()
java.lang.String	getExpiration()
java.lang.Integer	getMessageCount()
java.lang.String	getMessageId()
java.lang.Integer	getPriority()
MessageDeliveryMode	getReceivedDeliveryMode()
java.lang.String	getReceivedExchange()
java.lang.String	getReceivedRoutingKey()
java.lang.String	getReceivedUserId()
java.lang.Boolean	getRedelivered()
java.lang.String	getReplyTo()
java.lang.Long	getTimestamp()
java.lang.String	getType()
java.lang.String	getUserId()
protected void	verifyType(java.lang.String headerName, java.lang.Object headerValue)
static AmqpMessageHeaderAccessor	wrap(Message<?> message)	Create a AmqpMessageHeaderAccessor from the headers of an existing message.

Methods inherited from class org.springframework.messaging.support.NativeMessageHeaderAccessor

addNativeHeader, addNativeHeaders, containsNativeHeader, copyHeaders, copyHeadersIfAbsent, getFirstNativeHeader, getFirstNativeHeader, getNativeHeader, getNativeHeaders, removeNativeHeader, setImmutable, setNativeHeader, setNativeHeaderValues, toNativeHeaderMap

Methods inherited from class org.springframework.messaging.support.MessageHeaderAccessor

createAccessor, getAccessor, getAccessor, getAccessor, getDetailedLogMessage, getDetailedPayloadLogMessage, getErrorChannel, getHeader, getId, getMessageHeaders, getMutableAccessor, getReplyChannel, getShortLogMessage, getShortPayloadLogMessage, isModified, isMutable, isReadableContentType, isReadOnly, removeHeader, removeHeaders, setContentType, setErrorChannel, setErrorChannelName, setHeader, setHeaderIfAbsent, setLeaveMutable, setModified, setReplyChannel, setReplyChannelName, toMap, toMessageHeaders, toString

Methods inherited from class java.lang.Object

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

Field Detail

PRIORITY

public static final java.lang.String PRIORITY

See Also:

Constant Field Values

Constructor Detail

AmqpMessageHeaderAccessor

protected AmqpMessageHeaderAccessor(java.util.Map<java.lang.String,java.util.List<java.lang.String>> nativeHeaders)

AmqpMessageHeaderAccessor

protected AmqpMessageHeaderAccessor(Message<?> message)

Method Detail

wrap

public static AmqpMessageHeaderAccessor wrap(Message<?> message)

Create a AmqpMessageHeaderAccessor from the headers of an existing message.

Parameters:

message - the Message to be wrapped for this MessageHeaderAccessor.

Returns:

the AmqpMessageHeaderAccessor instance.

verifyType

protected void verifyType(java.lang.String headerName,
                          java.lang.Object headerValue)

Overrides:

verifyType in class MessageHeaderAccessor

getAppId

public java.lang.String getAppId()

getClusterId

public java.lang.String getClusterId()

getContentEncoding

public java.lang.String getContentEncoding()

getContentLength

public java.lang.Long getContentLength()

getContentType

public MimeType getContentType()

Overrides:

getContentType in class MessageHeaderAccessor

getCorrelationId

public java.lang.String getCorrelationId()

getDeliveryMode

public MessageDeliveryMode getDeliveryMode()

getReceivedDeliveryMode

public MessageDeliveryMode getReceivedDeliveryMode()

getDeliveryTag

public java.lang.Long getDeliveryTag()

getExpiration

public java.lang.String getExpiration()

getMessageCount

public java.lang.Integer getMessageCount()

getMessageId

public java.lang.String getMessageId()

getPriority

public java.lang.Integer getPriority()

getReceivedExchange

public java.lang.String getReceivedExchange()

getReceivedRoutingKey

public java.lang.String getReceivedRoutingKey()

getReceivedUserId

public java.lang.String getReceivedUserId()

getRedelivered

public java.lang.Boolean getRedelivered()

getReplyTo

public java.lang.String getReplyTo()

getTimestamp

public java.lang.Long getTimestamp()

Overrides:

getTimestamp in class MessageHeaderAccessor

getType

public java.lang.String getType()

getUserId

public java.lang.String getUserId()

getConsumerTag

public java.lang.String getConsumerTag()

getConsumerQueue

public java.lang.String getConsumerQueue()