public class AmqpMessageHeaderAccessor
extends org.springframework.messaging.support.NativeMessageHeaderAccessor
MessageHeaderAccessor
implementation giving access to AMQP-specific headers.Modifier and Type | Field and Description |
---|---|
static String |
PRIORITY |
Modifier | Constructor and Description |
---|---|
protected |
AmqpMessageHeaderAccessor(Map<String,List<String>> nativeHeaders) |
protected |
AmqpMessageHeaderAccessor(org.springframework.messaging.Message<?> message) |
addNativeHeader, addNativeHeaders, containsNativeHeader, getFirstNativeHeader, getFirstNativeHeader, getNativeHeader, getNativeHeaders, removeNativeHeader, setImmutable, setNativeHeader, toNativeHeaderMap
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
public static final String PRIORITY
protected AmqpMessageHeaderAccessor(Map<String,List<String>> nativeHeaders)
protected AmqpMessageHeaderAccessor(org.springframework.messaging.Message<?> message)
public static AmqpMessageHeaderAccessor wrap(org.springframework.messaging.Message<?> message)
AmqpMessageHeaderAccessor
from the headers of an existing message.message
- the Message
to be wrapped for this
MessageHeaderAccessor
.AmqpMessageHeaderAccessor
instance.protected void verifyType(String headerName, Object headerValue)
verifyType
in class org.springframework.messaging.support.MessageHeaderAccessor
public String getAppId()
public String getClusterId()
public String getContentEncoding()
public Long getContentLength()
public org.springframework.util.MimeType getContentType()
getContentType
in class org.springframework.messaging.support.MessageHeaderAccessor
public String getCorrelationId()
@Deprecated public String getCorrelationIdString()
getCorrelationId()
.public MessageDeliveryMode getDeliveryMode()
public MessageDeliveryMode getReceivedDeliveryMode()
public Long getDeliveryTag()
public String getExpiration()
public Integer getMessageCount()
public String getMessageId()
public Integer getPriority()
public String getReceivedExchange()
public String getReceivedRoutingKey()
public String getReceivedUserId()
public Boolean getRedelivered()
public String getReplyTo()
public Long getTimestamp()
getTimestamp
in class org.springframework.messaging.support.MessageHeaderAccessor
public String getType()
public String getUserId()
public String getConsumerTag()
public String getConsumerQueue()