クラス MessageProperties

メソッドの詳細

• setHeader

  public void setHeader(StringSE key, ObjectSE value)

• setHeaders

  public void setHeaders(MapSE<StringSE,ObjectSE> headers)

  ヘッダーを設定します。

  パラメーター:

  headers - ヘッダー。

  導入:

  2.4.7

• getHeader

  public <T> @Nullable T getHeader(StringSE headerName)

  ヘッダーに getter と入力しました。

  型パラメーター:

  T - 型。

  パラメーター:

  headerName - ヘッダー名。

  戻り値:

  ヘッダー値

  導入:

  2.2

• getHeaders

  public MapSE<StringSE,@Nullable ObjectSE> getHeaders()

• setTimestamp

  public void setTimestamp(DateSE timestamp)

• getTimestamp

  public @Nullable DateSE getTimestamp()

• setMessageId

  public void setMessageId(StringSE messageId)

• getMessageId

  public @Nullable StringSE getMessageId()

• setUserId

  public void setUserId(StringSE userId)

• getUserId

  public @Nullable StringSE getUserId()

• getReceivedUserId

  public @Nullable StringSE getReceivedUserId()

  受信メッセージからユーザー ID を返します。

  戻り値:

  ユーザー ID。

  導入:

  1.6

• setReceivedUserId

  public void setReceivedUserId(StringSE receivedUserId)

• setAppId

  public void setAppId(StringSE appId)

• getAppId

  public @Nullable StringSE getAppId()

• setClusterId

  public void setClusterId(StringSE clusterId)

• getClusterId

  public @Nullable StringSE getClusterId()

• setType

  public void setType(StringSE type)

• getType

  public @Nullable StringSE getType()

• setCorrelationId

  public void setCorrelationId(@Nullable StringSE correlationId)

  相関 ID を設定します。

  パラメーター:

  correlationId - ID。

• getCorrelationId

  public @Nullable StringSE getCorrelationId()

  相関 ID を取得します。

  戻り値:

  ID。

• setReplyTo

  public void setReplyTo(@Nullable StringSE replyTo)

• getReplyTo

  public @Nullable StringSE getReplyTo()

• setReplyToAddress

  public void setReplyToAddress(@Nullable Address replyTo)

• getReplyToAddress

  public @Nullable Address getReplyToAddress()

• setContentType

  public void setContentType(StringSE contentType)

• getContentType

  public StringSE getContentType()

• setContentEncoding

  public void setContentEncoding(@Nullable StringSE contentEncoding)

• getContentEncoding

  public @Nullable StringSE getContentEncoding()

• setContentLength

  public void setContentLength(long contentLength)

• getContentLength

  public long getContentLength()

• isContentLengthSet

  protected final boolean isContentLengthSet()

• setDeliveryMode

  public void setDeliveryMode(@Nullable MessageDeliveryMode deliveryMode)

• getDeliveryMode

  public @Nullable MessageDeliveryMode getDeliveryMode()

• getReceivedDeliveryMode

  public @Nullable MessageDeliveryMode getReceivedDeliveryMode()

• setReceivedDeliveryMode

  public void setReceivedDeliveryMode(MessageDeliveryMode receivedDeliveryMode)

• setExpiration

  public void setExpiration(StringSE expiration)

  メッセージの有効期限を設定します。これは、AMQP 0.9.1 仕様ごとの String プロパティです。RabbitMQ の場合、これはメッセージの存続時間をミリ秒単位で表した文字列です。

  パラメーター:

  expiration - 有効期限。

• getExpiration

  public @Nullable StringSE getExpiration()

  メッセージの有効期限を取得します。これは、AMQP 0.9.1 仕様ごとの String プロパティです。RabbitMQ の場合、これはメッセージの存続時間をミリ秒単位で表した文字列です。

  戻り値:

  有効期限。

• setPriority

  public void setPriority(IntegerSE priority)

• getPriority

  public IntegerSE getPriority()

• setReceivedExchange

  public void setReceivedExchange(StringSE receivedExchange)

• getReceivedExchange

  public @Nullable StringSE getReceivedExchange()

• setReceivedRoutingKey

  public void setReceivedRoutingKey(StringSE receivedRoutingKey)

• getReceivedRoutingKey

  public @Nullable StringSE getReceivedRoutingKey()

• getReceivedDelayLong

  public @Nullable LongSE getReceivedDelayLong()

  遅延メッセージ交換が使用される場合、受信メッセージの x-delay ヘッダーに遅延が含まれます。

  戻り値:

  受け取った遅延。

  導入:

  3.1.2

  関連事項:

  • getDelayLong()

• setReceivedDelayLong

  public void setReceivedDelayLong(LongSE receivedDelay)

  遅延メッセージ交換が使用される場合、受信メッセージの x-delay ヘッダーに遅延が含まれます。

  パラメーター:

  receivedDelay - 受け取った遅延。

  導入:

  3.1.2

  関連事項:

  • setDelayLong(Long)

• setRedelivered

  public void setRedelivered(BooleanSE redelivered)

• isRedelivered

  public @Nullable BooleanSE isRedelivered()

• getRedelivered

  public @Nullable BooleanSE getRedelivered()

• setDeliveryTag

  public void setDeliveryTag(long deliveryTag)

• getDeliveryTag

  public long getDeliveryTag()

• isDeliveryTagSet

  protected final boolean isDeliveryTagSet()

• setMessageCount

  public void setMessageCount(IntegerSE messageCount)

  メッセージ数を設定します。

  パラメーター:

  messageCount - カウント

  関連事項:

  • getMessageCount()

• getMessageCount

  public @Nullable IntegerSE getMessageCount()

  キューに残っているメッセージ数のサーバーの最新の見積もりを返します。basicGet 経由で取得されたメッセージにのみ適用されます。

  戻り値:

  カウント。

• getConsumerTag

  public @Nullable StringSE getConsumerTag()

• setConsumerTag

  public void setConsumerTag(StringSE consumerTag)

• getConsumerQueue

  public @Nullable StringSE getConsumerQueue()

• setConsumerQueue

  public void setConsumerQueue(StringSE consumerQueue)

• getDelayLong

  public @Nullable LongSE getDelayLong()

  X-Delay ヘッダーの Long 値を取得します。

  戻り値:

  遅延。

  導入:

  3.1.2

• setDelayLong

  public void setDelayLong(@Nullable LongSE delay)

  x-lay ヘッダーを長い値に設定します。

  パラメーター:

  delay - 遅延。

  導入:

  3.1.2

• getRetryCount

  public long getRetryCount()

  ブローカー経由のこのメッセージの再試行回数。

  戻り値:

  再試行回数

  導入:

  3.2

• setRetryCount

  public void setRetryCount(long retryCount)

  ブローカー経由でこのメッセージの再試行回数を設定します。

  パラメーター:

  retryCount - 再試行回数。

  導入:

  3.2

  関連事項:

  • incrementRetryCount()

• incrementRetryCount

  public void incrementRetryCount()

  このメッセージがブローカーに再発行されるときに、このメッセージの再試行回数を増やします。

  導入:

  3.2

• 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 @Nullable TypeSE getInferredArgumentType()

  メソッドレベルの @RabbitListener を使用する場合に推定されるターゲット引数の型。

  戻り値:

  型。

  導入:

  1.6

• setInferredArgumentType

  public void setInferredArgumentType(TypeSE inferredArgumentType)

  メソッドレベルの @RabbitListener を使用する場合は、推定されるターゲット引数の型を設定します。

  パラメーター:

  inferredArgumentType - 型。

  導入:

  1.6

• getTargetMethod

  public @Nullable MethodSE getTargetMethod()

  @RabbitListener を使用する場合のターゲットメソッド。

  戻り値:

  メソッド。

  導入:

  1.6

• setTargetMethod

  public void setTargetMethod(@Nullable MethodSE targetMethod)

  @RabbitListener を使用する場合のターゲットメソッドを設定します。

  パラメーター:

  targetMethod - ターゲットメソッド。

  導入:

  1.6

• getTargetBean

  public @Nullable ObjectSE getTargetBean()

  @RabbitListener を使用する場合のターゲット Bean。

  戻り値:

  Bean。

  導入:

  1.6

• setTargetBean

  public void setTargetBean(@Nullable ObjectSE 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 @Nullable ListSE<MapSE<StringSE,?>> getXDeathHeader()

  x-death ヘッダーを返します。

  戻り値:

  ヘッダー。

• getAmqpAcknowledgment

  public @Nullable AmqpAcknowledgment getAmqpAcknowledgment()

  コンシューマー向けの AmqpAcknowledgment がある場合はそれを返却します。

  戻り値:

  コンシューマー向けの AmqpAcknowledgment (存在する場合)。

  導入:

  4.0

• setAmqpAcknowledgment

  public void setAmqpAcknowledgment(AmqpAcknowledgment amqpAcknowledgment)

  ターゲットメッセージプロセッサーで手動確認応答（ACK）用の AmqpAcknowledgment を設定します。これはアプリケーション内、コンシューマー側ロジックのみで実行されます。

  パラメーター:

  amqpAcknowledgment - アプリケーションで使用する AmqpAcknowledgment。

  導入:

  4.0

• hashCode

  public int hashCode()

  オーバーライド:

  クラス ObjectSE の hashCode 

• equals

  public boolean equals(ObjectSE obj)

  オーバーライド:

  クラス ObjectSE の equalsSE 

• toString

  public StringSE toString()

  オーバーライド:

  クラス ObjectSE の toString