クラス MessageProperties
- java.lang.Object
-
- org.springframework.amqp.core.MessageProperties
- 実装されたすべてのインターフェース:
java.io.Serializable
- 既知の直属サブクラス
StreamMessageProperties
public class MessageProperties extends java.lang.Object implements java.io.Serializable
AMQP メッセージのメッセージプロパティ。- 作成者:
- Mark Fisher, Mark Pollack, Gary Russell, Dmitry Chernyshov, Artem Bilan, Csaba Soti
- 関連事項:
- 直列化された形式
フィールドサマリー
フィールド 修飾子と型 フィールド 説明 static java.lang.String
BATCH_FORMAT_LENGTH_HEADER4
static java.lang.String
CONTENT_TYPE_BYTES
static java.lang.String
CONTENT_TYPE_JSON
static java.lang.String
CONTENT_TYPE_JSON_ALT
static java.lang.String
CONTENT_TYPE_SERIALIZED_OBJECT
static java.lang.String
CONTENT_TYPE_TEXT_PLAIN
static java.lang.String
CONTENT_TYPE_XML
static java.lang.String
DEFAULT_CONTENT_TYPE
static MessageDeliveryMode
DEFAULT_DELIVERY_MODE
static java.lang.Integer
DEFAULT_PRIORITY
static java.lang.String
SPRING_AUTO_DECOMPRESS
static java.lang.String
SPRING_BATCH_FORMAT
static java.lang.String
X_DELAY
コンストラクターのサマリー
コンストラクター コンストラクター 説明 MessageProperties()
メソッドのサマリー
すべてのメソッド インスタンスメソッド 具象メソッド 修飾子と型 メソッド 説明 boolean
equals(java.lang.Object obj)
java.lang.String
getAppId()
java.lang.String
getClusterId()
java.lang.String
getConsumerQueue()
java.lang.String
getConsumerTag()
java.lang.String
getContentEncoding()
long
getContentLength()
java.lang.String
getContentType()
java.lang.String
getCorrelationId()
相関 ID を取得します。java.lang.Integer
getDelay()
x-delay ヘッダー (送信)。MessageDeliveryMode
getDeliveryMode()
long
getDeliveryTag()
java.lang.String
getExpiration()
メッセージの有効期限を取得します。<T> T
getHeader(java.lang.String headerName)
ヘッダーに getter と入力しました。java.util.Map<java.lang.String,java.lang.Object>
getHeaders()
java.lang.reflect.Type
getInferredArgumentType()
メソッドレベルの@RabbitListener
を使用する場合に推定されるターゲット引数の型。java.lang.Integer
getMessageCount()
キューに残っているメッセージ数のサーバーの最新の見積もりを返します。java.lang.String
getMessageId()
java.lang.Integer
getPriority()
long
getPublishSequenceNumber()
パブリッシャーの確認が有効になっている場合は、パブリッシュシーケンス番号を返します。テンプレートで設定。java.lang.Integer
getReceivedDelay()
遅延メッセージ交換が使用される場合、受信メッセージの x-delay ヘッダーに遅延が含まれます。MessageDeliveryMode
getReceivedDeliveryMode()
java.lang.String
getReceivedExchange()
java.lang.String
getReceivedRoutingKey()
java.lang.String
getReceivedUserId()
受信メッセージからユーザー ID を返します。java.lang.Boolean
getRedelivered()
java.lang.String
getReplyTo()
Address
getReplyToAddress()
java.lang.Object
getTargetBean()
@RabbitListener
を使用する場合のターゲット Bean。java.lang.reflect.Method
getTargetMethod()
@RabbitListener
を使用する場合のターゲットメソッド。java.util.Date
getTimestamp()
java.lang.String
getType()
java.lang.String
getUserId()
java.util.List<java.util.Map<java.lang.String,?>>
getXDeathHeader()
x-death ヘッダーを返します。int
hashCode()
protected boolean
isContentLengthSet()
protected boolean
isDeliveryTagSet()
boolean
isFinalRetryForMessageWithNoId()
boolean
isLastInBatch()
true の場合。これらのプロパティを持つメッセージは、バッチからの最後のメッセージです。boolean
isProjectionUsed()
変換が射影を使用したことを伝えるために使用される内部フラグを取得します。アプリケーションレベルでは常に false です。java.lang.Boolean
isRedelivered()
void
setAppId(java.lang.String appId)
void
setClusterId(java.lang.String clusterId)
void
setConsumerQueue(java.lang.String consumerQueue)
void
setConsumerTag(java.lang.String consumerTag)
void
setContentEncoding(java.lang.String contentEncoding)
void
setContentLength(long contentLength)
void
setContentType(java.lang.String contentType)
void
setCorrelationId(java.lang.String correlationId)
相関 ID を設定します。void
setDelay(java.lang.Integer delay)
x-delay ヘッダーを設定します。void
setDeliveryMode(MessageDeliveryMode deliveryMode)
void
setDeliveryTag(long deliveryTag)
void
setExpiration(java.lang.String expiration)
メッセージの有効期限を設定します。void
setFinalRetryForMessageWithNoId(boolean finalRetryForMessageWithNoId)
void
setHeader(java.lang.String key, java.lang.Object value)
void
setHeaders(java.util.Map<java.lang.String,java.lang.Object> headers)
ヘッダーを設定します。void
setInferredArgumentType(java.lang.reflect.Type inferredArgumentType)
メソッドレベルの@RabbitListener
を使用する場合は、推定されるターゲット引数の型を設定します。void
setLastInBatch(boolean lastInBatch)
これらのプロパティがバッチ内の最後のメッセージ用であることを示すには、true に設定します。void
setMessageCount(java.lang.Integer messageCount)
メッセージ数を設定します。void
setMessageId(java.lang.String messageId)
void
setPriority(java.lang.Integer priority)
void
setProjectionUsed(boolean projectionUsed)
変換が射影を使用したことを伝えるために使用される内部フラグを設定します。アプリケーションレベルでは常に false です。void
setPublishSequenceNumber(long publishSequenceNumber)
パブリッシャーの確認が有効になっている場合は、パブリッシュシーケンス番号を設定します。テンプレートで設定。void
setReceivedDelay(java.lang.Integer receivedDelay)
遅延メッセージ交換が使用される場合、受信メッセージの x-delay ヘッダーに遅延が含まれます。void
setReceivedDeliveryMode(MessageDeliveryMode receivedDeliveryMode)
void
setReceivedExchange(java.lang.String receivedExchange)
void
setReceivedRoutingKey(java.lang.String receivedRoutingKey)
void
setReceivedUserId(java.lang.String receivedUserId)
void
setRedelivered(java.lang.Boolean redelivered)
void
setReplyTo(java.lang.String replyTo)
void
setReplyToAddress(Address replyTo)
void
setTargetBean(java.lang.Object targetBean)
@RabbitListener
を使用する場合は、対象の Bean を設定します。void
setTargetMethod(java.lang.reflect.Method targetMethod)
@RabbitListener
を使用する場合のターゲットメソッドを設定します。void
setTimestamp(java.util.Date timestamp)
void
setType(java.lang.String type)
void
setUserId(java.lang.String userId)
java.lang.String
toString()
フィールドの詳細
CONTENT_TYPE_BYTES
public static final java.lang.String CONTENT_TYPE_BYTES
- 関連事項:
- 定数フィールド値
CONTENT_TYPE_TEXT_PLAIN
public static final java.lang.String CONTENT_TYPE_TEXT_PLAIN
- 関連事項:
- 定数フィールド値
CONTENT_TYPE_SERIALIZED_OBJECT
public static final java.lang.String CONTENT_TYPE_SERIALIZED_OBJECT
- 関連事項:
- 定数フィールド値
CONTENT_TYPE_JSON
public static final java.lang.String CONTENT_TYPE_JSON
- 関連事項:
- 定数フィールド値
CONTENT_TYPE_JSON_ALT
public static final java.lang.String CONTENT_TYPE_JSON_ALT
- 関連事項:
- 定数フィールド値
CONTENT_TYPE_XML
public static final java.lang.String CONTENT_TYPE_XML
- 関連事項:
- 定数フィールド値
SPRING_BATCH_FORMAT
public static final java.lang.String SPRING_BATCH_FORMAT
- 関連事項:
- 定数フィールド値
BATCH_FORMAT_LENGTH_HEADER4
public static final java.lang.String BATCH_FORMAT_LENGTH_HEADER4
- 関連事項:
- 定数フィールド値
SPRING_AUTO_DECOMPRESS
public static final java.lang.String SPRING_AUTO_DECOMPRESS
- 関連事項:
- 定数フィールド値
X_DELAY
public static final java.lang.String X_DELAY
- 関連事項:
- 定数フィールド値
DEFAULT_CONTENT_TYPE
public static final java.lang.String DEFAULT_CONTENT_TYPE
- 関連事項:
- 定数フィールド値
DEFAULT_DELIVERY_MODE
public static final MessageDeliveryMode DEFAULT_DELIVERY_MODE
DEFAULT_PRIORITY
public static final java.lang.Integer DEFAULT_PRIORITY
メソッドの詳細
setHeader
public void setHeader(java.lang.String key, java.lang.Object value)
setHeaders
public void setHeaders(java.util.Map<java.lang.String,java.lang.Object> headers)
ヘッダーを設定します。- パラメーター:
headers
- ヘッダー。- 導入:
- 2.4.7
getHeader
public <T> T getHeader(java.lang.String headerName)
ヘッダーに getter と入力しました。- 型パラメーター:
T
- 型。- パラメーター:
headerName
- ヘッダー名。- 戻り値:
- ヘッダー値
- 導入:
- 2.2
getHeaders
public java.util.Map<java.lang.String,java.lang.Object> getHeaders()
setTimestamp
public void setTimestamp(java.util.Date timestamp)
getTimestamp
public java.util.Date getTimestamp()
setMessageId
public void setMessageId(java.lang.String messageId)
getMessageId
public java.lang.String getMessageId()
setUserId
public void setUserId(java.lang.String userId)
getUserId
public java.lang.String getUserId()
getReceivedUserId
public java.lang.String getReceivedUserId()
受信メッセージからユーザー ID を返します。- 戻り値:
- ユーザー ID。
- 導入:
- 1.6
setReceivedUserId
public void setReceivedUserId(java.lang.String receivedUserId)
setAppId
public void setAppId(java.lang.String appId)
getAppId
public java.lang.String getAppId()
setClusterId
public void setClusterId(java.lang.String clusterId)
getClusterId
public java.lang.String getClusterId()
setType
public void setType(java.lang.String type)
getType
public java.lang.String getType()
setCorrelationId
public void setCorrelationId(java.lang.String correlationId)
相関 ID を設定します。- パラメーター:
correlationId
- ID。
getCorrelationId
public java.lang.String getCorrelationId()
相関 ID を取得します。- 戻り値:
- ID。
setReplyTo
public void setReplyTo(java.lang.String replyTo)
getReplyTo
public java.lang.String getReplyTo()
setReplyToAddress
public void setReplyToAddress(Address replyTo)
getReplyToAddress
public Address getReplyToAddress()
setContentType
public void setContentType(java.lang.String contentType)
getContentType
public java.lang.String getContentType()
setContentEncoding
public void setContentEncoding(java.lang.String contentEncoding)
getContentEncoding
public java.lang.String getContentEncoding()
setContentLength
public void setContentLength(long contentLength)
getContentLength
public long getContentLength()
isContentLengthSet
protected final boolean isContentLengthSet()
setDeliveryMode
public void setDeliveryMode(MessageDeliveryMode deliveryMode)
getDeliveryMode
public MessageDeliveryMode getDeliveryMode()
getReceivedDeliveryMode
public MessageDeliveryMode getReceivedDeliveryMode()
setReceivedDeliveryMode
public void setReceivedDeliveryMode(MessageDeliveryMode receivedDeliveryMode)
setExpiration
public void setExpiration(java.lang.String expiration)
メッセージの有効期限を設定します。これは、AMQP 0.9.1 仕様ごとの String プロパティです。RabbitMQ の場合、これはメッセージの存続時間をミリ秒単位で表した文字列です。- パラメーター:
expiration
- 有効期限。
getExpiration
public java.lang.String getExpiration()
メッセージの有効期限を取得します。これは、AMQP 0.9.1 仕様ごとの String プロパティです。RabbitMQ の場合、これはメッセージの存続時間をミリ秒単位で表した文字列です。- 戻り値:
- 有効期限。
setPriority
public void setPriority(java.lang.Integer priority)
getPriority
public java.lang.Integer getPriority()
setReceivedExchange
public void setReceivedExchange(java.lang.String receivedExchange)
getReceivedExchange
public java.lang.String getReceivedExchange()
setReceivedRoutingKey
public void setReceivedRoutingKey(java.lang.String receivedRoutingKey)
getReceivedRoutingKey
public java.lang.String getReceivedRoutingKey()
getReceivedDelay
public java.lang.Integer getReceivedDelay()
遅延メッセージ交換が使用される場合、受信メッセージの x-delay ヘッダーに遅延が含まれます。- 戻り値:
- 受け取った遅延。
- 導入:
- 1.6
- 関連事項:
getDelay()
setReceivedDelay
public void setReceivedDelay(java.lang.Integer receivedDelay)
遅延メッセージ交換が使用される場合、受信メッセージの x-delay ヘッダーに遅延が含まれます。- パラメーター:
receivedDelay
- 受け取った遅延。- 導入:
- 1.6
setRedelivered
public void setRedelivered(java.lang.Boolean redelivered)
isRedelivered
public java.lang.Boolean isRedelivered()
getRedelivered
public java.lang.Boolean getRedelivered()
setDeliveryTag
public void setDeliveryTag(long deliveryTag)
getDeliveryTag
public long getDeliveryTag()
isDeliveryTagSet
protected final boolean isDeliveryTagSet()
setMessageCount
public void setMessageCount(java.lang.Integer messageCount)
メッセージ数を設定します。- パラメーター:
messageCount
- カウント- 関連事項:
getMessageCount()
getMessageCount
public java.lang.Integer getMessageCount()
キューに残っているメッセージ数のサーバーの最新の見積もりを返します。basicGet
経由で取得されたメッセージにのみ適用されます。- 戻り値:
- カウント。
getConsumerTag
public java.lang.String getConsumerTag()
setConsumerTag
public void setConsumerTag(java.lang.String consumerTag)
getConsumerQueue
public java.lang.String getConsumerQueue()
setConsumerQueue
public void setConsumerQueue(java.lang.String consumerQueue)
getDelay
public java.lang.Integer getDelay()
x-delay ヘッダー (送信)。- 戻り値:
- 遅延。
- 導入:
- 1.6
- 関連事項:
getReceivedDelay()
setDelay
public void setDelay(java.lang.Integer delay)
x-delay ヘッダーを設定します。- パラメーター:
delay
- 遅延。- 導入:
- 1.6
isFinalRetryForMessageWithNoId
public boolean isFinalRetryForMessageWithNoId()
setFinalRetryForMessageWithNoId
public void setFinalRetryForMessageWithNoId(boolean finalRetryForMessageWithNoId)
getPublishSequenceNumber
public long getPublishSequenceNumber()
パブリッシャーの確認が有効になっている場合は、パブリッシュシーケンス番号を返します。テンプレートで設定。- 戻り値:
- シーケンス番号。
- 導入:
- 2.1
setPublishSequenceNumber
public void setPublishSequenceNumber(long publishSequenceNumber)
パブリッシャーの確認が有効になっている場合は、パブリッシュシーケンス番号を設定します。テンプレートで設定。- パラメーター:
publishSequenceNumber
- シーケンス番号。- 導入:
- 2.1
getInferredArgumentType
public java.lang.reflect.Type getInferredArgumentType()
メソッドレベルの@RabbitListener
を使用する場合に推定されるターゲット引数の型。- 戻り値:
- 型。
- 導入:
- 1.6
setInferredArgumentType
public void setInferredArgumentType(java.lang.reflect.Type inferredArgumentType)
メソッドレベルの@RabbitListener
を使用する場合は、推定されるターゲット引数の型を設定します。- パラメーター:
inferredArgumentType
- 型。- 導入:
- 1.6
getTargetMethod
public java.lang.reflect.Method getTargetMethod()
@RabbitListener
を使用する場合のターゲットメソッド。- 戻り値:
- メソッド。
- 導入:
- 1.6
setTargetMethod
public void setTargetMethod(java.lang.reflect.Method targetMethod)
@RabbitListener
を使用する場合のターゲットメソッドを設定します。- パラメーター:
targetMethod
- ターゲットメソッド。- 導入:
- 1.6
getTargetBean
public java.lang.Object getTargetBean()
@RabbitListener
を使用する場合のターゲット Bean。- 戻り値:
- Bean。
- 導入:
- 1.6
setTargetBean
public void setTargetBean(java.lang.Object targetBean)
@RabbitListener
を使用する場合は、対象の Bean を設定します。- パラメーター:
targetBean
- Bean。- 導入:
- 1.6
isLastInBatch
public boolean isLastInBatch()
true の場合。これらのプロパティを持つメッセージは、バッチからの最後のメッセージです。- 戻り値:
- 最後のメッセージの場合は true。
- 導入:
- 2.2
setLastInBatch
public void setLastInBatch(boolean lastInBatch)
これらのプロパティがバッチ内の最後のメッセージ用であることを示すには、true に設定します。- パラメーター:
lastInBatch
- 最後に当てはまります。- 導入:
- 2.2
isProjectionUsed
public boolean isProjectionUsed()
変換が射影を使用したことを伝えるために使用される内部フラグを取得します。アプリケーションレベルでは常に false です。- 戻り値:
- 射影が使用された場合は true。
- 導入:
- 2.2.20
setProjectionUsed
public void setProjectionUsed(boolean projectionUsed)
変換が射影を使用したことを伝えるために使用される内部フラグを設定します。アプリケーションレベルでは常に false です。- パラメーター:
projectionUsed
- 射影の場合は true。- 導入:
- 2.2.20
getXDeathHeader
public java.util.List<java.util.Map<java.lang.String,?>> getXDeathHeader()
x-death ヘッダーを返します。- 戻り値:
- ヘッダー。
hashCode
public int hashCode()
- オーバーライド:
- クラス
java.lang.Object
のhashCode
equals
public boolean equals(java.lang.Object obj)
- オーバーライド:
- クラス
java.lang.Object
のequals
toString
public java.lang.String toString()
- オーバーライド:
- クラス
java.lang.Object
のtoString