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, Artem Bilan

Field Summary

Fields

Modifier and Type	Field	Description
static final 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(Map<String, List<String>> nativeHeaders)
protected	AmqpMessageHeaderAccessor(Message<?> message)

Method Summary

Modifier and Type	Method	Description
@Nullable String	getAppId()
@Nullable String	getClusterId()
@Nullable String	getConsumerQueue()
@Nullable String	getConsumerTag()
@Nullable String	getContentEncoding()
@Nullable Long	getContentLength()
@Nullable MimeType	getContentType()
@Nullable String	getCorrelationId()
@Nullable MessageDeliveryMode	getDeliveryMode()
@Nullable Long	getDeliveryTag()
@Nullable String	getExpiration()
@Nullable Integer	getMessageCount()
@Nullable String	getMessageId()
@Nullable Integer	getPriority()
@Nullable MessageDeliveryMode	getReceivedDeliveryMode()
@Nullable String	getReceivedExchange()
@Nullable String	getReceivedRoutingKey()
@Nullable String	getReceivedUserId()
@Nullable Boolean	getRedelivered()
@Nullable String	getReplyTo()
@Nullable Long	getTimestamp()
@Nullable String	getType()
@Nullable String	getUserId()
protected void	verifyType(@Nullable String headerName, @Nullable 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, fromMap, fromMessageHeaders, 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 Details

PRIORITY

public static final String PRIORITY

See Also:

• Constant Field Values

Constructor Details

AmqpMessageHeaderAccessor

protected AmqpMessageHeaderAccessor(Map<String, List<String>> nativeHeaders)

AmqpMessageHeaderAccessor

protected AmqpMessageHeaderAccessor(Message<?> message)

Method Details

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(@Nullable String headerName,
 @Nullable Object headerValue)

Overrides:

verifyType in class MessageHeaderAccessor

getAppId

public @Nullable String getAppId()

getClusterId

public @Nullable String getClusterId()

getContentEncoding

public @Nullable String getContentEncoding()

getContentLength

public @Nullable Long getContentLength()

getContentType

public @Nullable MimeType getContentType()

Overrides:

getContentType in class MessageHeaderAccessor

getCorrelationId

public @Nullable String getCorrelationId()

getDeliveryMode

public @Nullable MessageDeliveryMode getDeliveryMode()

getReceivedDeliveryMode

public @Nullable MessageDeliveryMode getReceivedDeliveryMode()

getDeliveryTag

public @Nullable Long getDeliveryTag()

getExpiration

public @Nullable String getExpiration()

getMessageCount

public @Nullable Integer getMessageCount()

getMessageId

public @Nullable String getMessageId()

getPriority

public @Nullable Integer getPriority()

getReceivedExchange

public @Nullable String getReceivedExchange()

getReceivedRoutingKey

public @Nullable String getReceivedRoutingKey()

getReceivedUserId

public @Nullable String getReceivedUserId()

getRedelivered

public @Nullable Boolean getRedelivered()

getReplyTo

public @Nullable String getReplyTo()

getTimestamp

public @Nullable Long getTimestamp()

Overrides:

getTimestamp in class MessageHeaderAccessor

getType

public @Nullable String getType()

getUserId

public @Nullable String getUserId()

getConsumerTag

public @Nullable String getConsumerTag()

getConsumerQueue

public @Nullable String getConsumerQueue()