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

Field Summary

Fields

Modifier and Type	Field and Description
static String	PRIORITY

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

NATIVE_HEADERS

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

DEFAULT_CHARSET, logger

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AmqpMessageHeaderAccessor(Map<String,List<String>> nativeHeaders)
protected	AmqpMessageHeaderAccessor(Message<?> message)

Method Summary

Modifier and Type	Method and Description
String	getAppId()
String	getClusterId()
String	getContentEncoding()
Long	getContentLength()
MimeType	getContentType()
byte[]	getCorrelationId()
MessageDeliveryMode	getDeliveryMode()
Long	getDeliveryTag()
String	getExpiration()
Integer	getMessageCount()
String	getMessageId()
Integer	getPriority()
String	getReceivedExchange()
String	getReceivedRoutingKey()
Boolean	getRedelivered()
String	getReplyTo()
Long	getTimestamp()
String	getType()
String	getUserId()
protected void	verifyType(String headerName, 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, containsNativeHeader, getFirstNativeHeader, getNativeHeader, removeNativeHeader, setImmutable, setNativeHeader, toNativeHeaderMap

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

copyHeaders, copyHeadersIfAbsent, createAccessor, 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 String PRIORITY

See Also:

Constant Field Values

Constructor Detail

AmqpMessageHeaderAccessor

protected AmqpMessageHeaderAccessor(Map<String,List<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(String headerName,
                          Object headerValue)

Overrides:

verifyType in class MessageHeaderAccessor

getAppId

public String getAppId()

getClusterId

public String getClusterId()

getContentEncoding

public String getContentEncoding()

getContentLength

public Long getContentLength()

getContentType

public MimeType getContentType()

Overrides:

getContentType in class MessageHeaderAccessor

getCorrelationId

public byte[] getCorrelationId()

getDeliveryMode

public MessageDeliveryMode getDeliveryMode()

getDeliveryTag

public Long getDeliveryTag()

getExpiration

public String getExpiration()

getMessageCount

public Integer getMessageCount()

getMessageId

public String getMessageId()

getPriority

public Integer getPriority()

getReceivedExchange

public String getReceivedExchange()

getReceivedRoutingKey

public String getReceivedRoutingKey()

getRedelivered

public Boolean getRedelivered()

getReplyTo

public String getReplyTo()

getTimestamp

public Long getTimestamp()

Overrides:

getTimestamp in class MessageHeaderAccessor

getType

public String getType()

getUserId

public String getUserId()