クラス AmqpMessageHeaderAccessor
- java.lang.ObjectSE
-
- org.springframework.messaging.support.MessageHeaderAccessor
-
- org.springframework.messaging.support.NativeMessageHeaderAccessor
-
- org.springframework.amqp.support.AmqpMessageHeaderAccessor
public class AmqpMessageHeaderAccessor extends NativeMessageHeaderAccessor
AMQP 固有のヘッダーへのアクセスを提供するMessageHeaderAccessor実装。- 導入:
- 1.4
- 作成者:
- Stephane Nicoll, Gary Russell
フィールド概要
フィールド 修飾子と型 フィールド 説明 static StringSEPRIORITYクラス org.springframework.messaging.support.NativeMessageHeaderAccessor から継承されたフィールド
NATIVE_HEADERS
クラス org.springframework.messaging.support.MessageHeaderAccessor から継承されたフィールド
DEFAULT_CHARSET
コンストラクター概要
コンストラクター 修飾子 コンストラクター 説明 protectedAmqpMessageHeaderAccessor(MapSE<StringSE,ListSE<StringSE>> nativeHeaders)protectedAmqpMessageHeaderAccessor(Message<?> message)
方法の概要
すべてのメソッド 静的メソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 StringSEgetAppId()StringSEgetClusterId()StringSEgetConsumerQueue()StringSEgetConsumerTag()StringSEgetContentEncoding()LongSEgetContentLength()MimeTypegetContentType()StringSEgetCorrelationId()MessageDeliveryModegetDeliveryMode()LongSEgetDeliveryTag()StringSEgetExpiration()IntegerSEgetMessageCount()StringSEgetMessageId()IntegerSEgetPriority()MessageDeliveryModegetReceivedDeliveryMode()StringSEgetReceivedExchange()StringSEgetReceivedRoutingKey()StringSEgetReceivedUserId()BooleanSEgetRedelivered()StringSEgetReplyTo()LongSEgetTimestamp()StringSEgetType()StringSEgetUserId()protected voidverifyType(StringSE headerName, ObjectSE headerValue)static AmqpMessageHeaderAccessorwrap(Message<?> message)既存のメッセージのヘッダーからAmqpMessageHeaderAccessorを作成します。クラス org.springframework.messaging.support.NativeMessageHeaderAccessor から継承されたメソッド
addNativeHeader, addNativeHeaders, containsNativeHeader, copyHeaders, copyHeadersIfAbsent, getFirstNativeHeader, getFirstNativeHeader, getNativeHeader, getNativeHeaders, removeNativeHeader, setImmutable, setNativeHeader, setNativeHeaderValues, toNativeHeaderMap
クラス 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
メソッドの詳細
wrap
public static AmqpMessageHeaderAccessor wrap(Message<?> message)
既存のメッセージのヘッダーからAmqpMessageHeaderAccessorを作成します。- パラメーター:
message- このMessageHeaderAccessorに対してラップされるMessage。- 戻り値:
AmqpMessageHeaderAccessorインスタンス。
verifyType
protected void verifyType(StringSE headerName, ObjectSE headerValue)
- オーバーライド:
- クラス
MessageHeaderAccessorのverifyType
getAppId
public StringSE getAppId()
getClusterId
public StringSE getClusterId()
getContentEncoding
public StringSE getContentEncoding()
getContentLength
public LongSE getContentLength()
getContentType
public MimeType getContentType()
- オーバーライド:
- クラス
MessageHeaderAccessorのgetContentType
getCorrelationId
public StringSE getCorrelationId()
getDeliveryMode
public MessageDeliveryMode getDeliveryMode()
getReceivedDeliveryMode
public MessageDeliveryMode getReceivedDeliveryMode()
getDeliveryTag
public LongSE getDeliveryTag()
getExpiration
public StringSE getExpiration()
getMessageCount
public IntegerSE getMessageCount()
getMessageId
public StringSE getMessageId()
getPriority
public IntegerSE getPriority()
getReceivedExchange
public StringSE getReceivedExchange()
getReceivedRoutingKey
public StringSE getReceivedRoutingKey()
getReceivedUserId
public StringSE getReceivedUserId()
getRedelivered
public BooleanSE getRedelivered()
getReplyTo
public StringSE getReplyTo()
getTimestamp
public LongSE getTimestamp()
- オーバーライド:
- クラス
MessageHeaderAccessorのgetTimestamp
getType
public StringSE getType()
getUserId
public StringSE getUserId()
getConsumerTag
public StringSE getConsumerTag()
getConsumerQueue
public StringSE getConsumerQueue()