Class RabbitAmqpUtils

java.lang.Object

org.springframework.amqp.rabbitmq.client.RabbitAmqpUtils

public final class RabbitAmqpUtils
extends Object

The utilities for RabbitMQ AMQP 1.0 protocol API.

Method Summary

Modifier and Type	Method	Description
static Message	fromAmqpMessage(com.rabbitmq.client.amqp.Message amqpMessage, @Nullable com.rabbitmq.client.amqp.Consumer.Context context)	Convert Message into Message.
static void	toAmqpMessage(Message message, com.rabbitmq.client.amqp.Message amqpMessage)	Convert Message into Message.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

fromAmqpMessage

public static Message fromAmqpMessage(com.rabbitmq.client.amqp.Message amqpMessage,
 @Nullable com.rabbitmq.client.amqp.Consumer.Context context)

Convert Message into Message.

Parameters:

amqpMessage - the Message convert from.

context - the Consumer.Context for manual message settlement.

Returns:

the Message mapped from a Message.

toAmqpMessage

public static void toAmqpMessage(Message message,
 com.rabbitmq.client.amqp.Message amqpMessage)

Convert Message into Message. The MessageProperties.getReplyTo() is set into Message.to(String). The Message.correlationId(long) is set to MessageProperties.getCorrelationId() if present, or to MessageProperties.getMessageId().

Parameters:

message - the Message convert from.

amqpMessage - the Message convert into.