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.NativeMessageHeaderAccessor
A
MessageHeaderAccessor
implementation giving access to AMQP-specific headers.- Since:
- 1.4
-
Field Summary
FieldsFields inherited from class org.springframework.messaging.support.NativeMessageHeaderAccessor
NATIVE_HEADERSFields inherited from class org.springframework.messaging.support.MessageHeaderAccessor
DEFAULT_CHARSET -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedAmqpMessageHeaderAccessor(Map<String, List<String>> nativeHeaders) protectedAmqpMessageHeaderAccessor(org.springframework.messaging.Message<?> message) -
Method Summary
Modifier and TypeMethodDescriptiongetAppId()org.springframework.util.MimeTypegetType()protected voidverifyType(String headerName, 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, toNativeHeaderMapMethods 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 Details
-
PRIORITY
- See Also:
-
-
Constructor Details
-
AmqpMessageHeaderAccessor
-
AmqpMessageHeaderAccessor
protected AmqpMessageHeaderAccessor(org.springframework.messaging.Message<?> message)
-
-
Method Details
-
wrap
Create aAmqpMessageHeaderAccessorfrom the headers of an existing message.- Parameters:
message- theMessageto be wrapped for thisMessageHeaderAccessor.- Returns:
- the
AmqpMessageHeaderAccessorinstance.
-
verifyType
- Overrides:
verifyTypein classorg.springframework.messaging.support.MessageHeaderAccessor
-
getAppId
-
getClusterId
-
getContentEncoding
-
getContentLength
-
getContentType
public org.springframework.util.MimeType getContentType()- Overrides:
getContentTypein classorg.springframework.messaging.support.MessageHeaderAccessor
-
getCorrelationId
-
getDeliveryMode
-
getReceivedDeliveryMode
-
getDeliveryTag
-
getExpiration
-
getMessageCount
-
getMessageId
-
getPriority
-
getReceivedExchange
-
getReceivedRoutingKey
-
getReceivedUserId
-
getRedelivered
-
getReplyTo
-
getTimestamp
- Overrides:
getTimestampin classorg.springframework.messaging.support.MessageHeaderAccessor
-
getType
-
getUserId
-
getConsumerTag
-
getConsumerQueue
-