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 org.springframework.messaging.support.NativeMessageHeaderAccessorAMessageHeaderAccessorimplementation giving access to AMQP-specific headers.- Since:
- 1.4
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.StringPRIORITY
-
Constructor Summary
Constructors Modifier Constructor Description protectedAmqpMessageHeaderAccessor(java.util.Map<java.lang.String,java.util.List<java.lang.String>> nativeHeaders)protectedAmqpMessageHeaderAccessor(org.springframework.messaging.Message<?> message)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.StringgetAppId()java.lang.StringgetClusterId()java.lang.StringgetConsumerQueue()java.lang.StringgetConsumerTag()java.lang.StringgetContentEncoding()java.lang.LonggetContentLength()org.springframework.util.MimeTypegetContentType()java.lang.StringgetCorrelationId()MessageDeliveryModegetDeliveryMode()java.lang.LonggetDeliveryTag()java.lang.StringgetExpiration()java.lang.IntegergetMessageCount()java.lang.StringgetMessageId()java.lang.IntegergetPriority()MessageDeliveryModegetReceivedDeliveryMode()java.lang.StringgetReceivedExchange()java.lang.StringgetReceivedRoutingKey()java.lang.StringgetReceivedUserId()java.lang.BooleangetRedelivered()java.lang.StringgetReplyTo()java.lang.LonggetTimestamp()java.lang.StringgetType()java.lang.StringgetUserId()protected voidverifyType(java.lang.String headerName, java.lang.Object headerValue)static AmqpMessageHeaderAccessorwrap(org.springframework.messaging.Message<?> message)Create aAmqpMessageHeaderAccessorfrom 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
-
-
-
-
Field Detail
-
PRIORITY
public static final java.lang.String PRIORITY
- See Also:
- Constant Field Values
-
-
Method Detail
-
wrap
public static AmqpMessageHeaderAccessor wrap(org.springframework.messaging.Message<?> message)
Create aAmqpMessageHeaderAccessorfrom the headers of an existing message.- Parameters:
message- theMessageto be wrapped for thisMessageHeaderAccessor.- Returns:
- the
AmqpMessageHeaderAccessorinstance.
-
verifyType
protected void verifyType(java.lang.String headerName, java.lang.Object headerValue)- Overrides:
verifyTypein classorg.springframework.messaging.support.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 org.springframework.util.MimeType getContentType()
- Overrides:
getContentTypein classorg.springframework.messaging.support.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:
getTimestampin classorg.springframework.messaging.support.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()
-
-