クラス RabbitAmqpUtils

java.lang.ObjectSE
org.springframework.amqp.rabbitmq.client.RabbitAmqpUtils
public final class RabbitAmqpUtils extends ObjectSE
RabbitMQ AMQP 1.0 プロトコル API 用のユーティリティ。

  • メソッドの詳細

    • fromAmqpMessage

      public static Message fromAmqpMessage(com.rabbitmq.client.amqp.Message amqpMessage, @Nullable com.rabbitmq.client.amqp.Consumer.Context context)
      Message を Message に変換します。
      パラメーター:
      amqpMessage - Message からの変換。
      context - 手動メッセージ決済用の Consumer.Context。
      戻り値:
      Message からマップされた Message。

    • toAmqpMessage

      public static void toAmqpMessage(Message message, com.rabbitmq.client.amqp.Message amqpMessage)
      Message を Message に変換します。MessageProperties.getReplyTo() は Message.to(String) に設定されます。Message.correlationId(long) は、MessageProperties.getCorrelationId() が存在する場合は MessageProperties.getCorrelationId() に、存在しない場合は MessageProperties.getMessageId() に設定されます。
      パラメーター:
      message - Message からの変換。
      amqpMessage - Message に変換します。