Uses of Class
org.springframework.amqp.core.Message

Packages that use Message

Package	Description
org.springframework.amqp.core	Provides core classes for the spring AMQP abstraction.
org.springframework.amqp.rabbit	Provides top-level classes for Spring Rabbit.
org.springframework.amqp.rabbit.batch	Provides classes for message batching.
org.springframework.amqp.rabbit.core	Provides core classes for Spring Rabbit.
org.springframework.amqp.rabbit.listener	Provides classes for message listener containers.
org.springframework.amqp.rabbit.listener.adapter	Provides classes for adapting listeners.
org.springframework.amqp.rabbit.listener.api	Provides Additional APIs for listeners.
org.springframework.amqp.rabbit.log4j2	Provides classes supporting Log4j 2 appenders.
org.springframework.amqp.rabbit.logback	Provides classes supporting Logback appenders.
org.springframework.amqp.rabbit.retry	Provides classes supporting retries.
org.springframework.amqp.rabbit.support	Provides support classes for Spring Rabbit.
org.springframework.amqp.rabbit.support.micrometer	Provides classes for Micrometer support.
org.springframework.amqp.rabbit.test	Classes for testing Spring AMQP applications.
org.springframework.amqp.rabbitmq.client	Provides Spring support for RabbitMQ AMQP 1.0 Client.
org.springframework.amqp.rabbitmq.client.listener	Provides Spring support for RabbitMQ AMQP 1.0 Consumer.
org.springframework.amqp.support.converter	Provides classes for supporting message conversion.
org.springframework.amqp.support.postprocessor	Package for Spring AMQP message post processors.
org.springframework.rabbit.stream.producer	Provides classes for stream producers.
org.springframework.rabbit.stream.retry	Provides classes supporting retries.
org.springframework.rabbit.stream.support.converter	Provides classes for message conversion.

Uses of Message in org.springframework.amqp.core

Subclasses with type arguments of type Message in org.springframework.amqp.core

Modifier and Type	Class	Description
final class	MessageBuilder	Builds a Spring AMQP Message either from a byte[] body or another Message using a fluent API.

Subinterfaces with type arguments of type Message in org.springframework.amqp.core

Modifier and Type	Interface	Description
interface	ReceiveAndReplyMessageCallback	Message exchanging contract of ReceiveAndReplyCallback.
interface	ReceiveAndReplyMessageCallback	Message exchanging contract of ReceiveAndReplyCallback.

Methods in org.springframework.amqp.core that return Message

Modifier and Type	Method	Description
Message	MessageBuilder.build()
Message	ReturnedMessage.getMessage()	Get the message.
Message	AmqpReplyTimeoutException.getRequestMessage()
Message	AmqpMessageReturnedException.getReturnedMessage()
Message	MessagePostProcessor.postProcessMessage(Message message)	Change (or replace) the message.
default Message	MessagePostProcessor.postProcessMessage(Message message, @Nullable Correlation correlation)	Change (or replace) the message and/or change its correlation data.
default Message	MessagePostProcessor.postProcessMessage(Message message, @Nullable Correlation correlation, String exchange, String routingKey)	Change (or replace) the message and/or change its correlation data.
@Nullable Message	AmqpTemplate.receive()	Receive a message if there is one from a default queue.
@Nullable Message	AmqpTemplate.receive(long timeoutMillis)	Receive a message from a default queue, waiting up to the specified wait time if necessary for a message to become available.
@Nullable Message	AmqpTemplate.receive(String queueName)	Receive a message if there is one from a specific queue.
@Nullable Message	AmqpTemplate.receive(String queueName, long timeoutMillis)	Receive a message from a specific queue, waiting up to the specified wait time if necessary for a message to become available.
@Nullable Message	AmqpTemplate.sendAndReceive(String exchange, String routingKey, Message message)	Basic RPC pattern.
@Nullable Message	AmqpTemplate.sendAndReceive(String routingKey, Message message)	Basic RPC pattern.
@Nullable Message	AmqpTemplate.sendAndReceive(Message message)	Basic RPC pattern.

Methods in org.springframework.amqp.core that return types with arguments of type Message

Modifier and Type	Method	Description
default CompletableFuture<Message>	AsyncAmqpTemplate.receive()
default CompletableFuture<Message>	AsyncAmqpTemplate.receive(String queueName)
CompletableFuture<Message>	AsyncAmqpTemplate.sendAndReceive(String exchange, @Nullable String routingKey, Message message)	Send a message to the supplied exchange and routing key.
CompletableFuture<Message>	AsyncAmqpTemplate.sendAndReceive(String routingKey, Message message)	Send a message to the default exchange with the supplied routing key.
CompletableFuture<Message>	AsyncAmqpTemplate.sendAndReceive(Message message)	Send a message to the default exchange with the default routing key.

Methods in org.springframework.amqp.core with parameters of type Message

Modifier and Type	Method	Description
static MessageBuilder	MessageBuilder.fromClonedMessage(Message message)	The final message will have a copy of the message body, the MessageProperties will be cloned (top level only).
static MessageBuilder	MessageBuilder.fromMessage(Message message)	The final message body will be a direct reference to the message body, the MessageProperties will be a shallow copy.
Address	ReplyToAddressCallback.getReplyToAddress(Message request, T reply)
default void	BatchMessageListener.onMessage(Message message)
void	MessageListener.onMessage(Message message)	Delivers a single message.
Message	MessagePostProcessor.postProcessMessage(Message message)	Change (or replace) the message.
default Message	MessagePostProcessor.postProcessMessage(Message message, @Nullable Correlation correlation)	Change (or replace) the message and/or change its correlation data.
default Message	MessagePostProcessor.postProcessMessage(Message message, @Nullable Correlation correlation, String exchange, String routingKey)	Change (or replace) the message and/or change its correlation data.
void	AmqpTemplate.send(String exchange, String routingKey, Message message)	Send a message to a specific exchange with a specific routing key.
void	AmqpTemplate.send(String routingKey, Message message)	Send a message to a default exchange with a specific routing key.
void	AmqpTemplate.send(Message message)	Send a message to a default exchange with a default routing key.
default CompletableFuture<Boolean>	AsyncAmqpTemplate.send(String exchange, @Nullable String routingKey, Message message)
default CompletableFuture<Boolean>	AsyncAmqpTemplate.send(String queue, Message message)
default CompletableFuture<Boolean>	AsyncAmqpTemplate.send(Message message)
@Nullable Message	AmqpTemplate.sendAndReceive(String exchange, String routingKey, Message message)	Basic RPC pattern.
@Nullable Message	AmqpTemplate.sendAndReceive(String routingKey, Message message)	Basic RPC pattern.
@Nullable Message	AmqpTemplate.sendAndReceive(Message message)	Basic RPC pattern.
CompletableFuture<Message>	AsyncAmqpTemplate.sendAndReceive(String exchange, @Nullable String routingKey, Message message)	Send a message to the supplied exchange and routing key.
CompletableFuture<Message>	AsyncAmqpTemplate.sendAndReceive(String routingKey, Message message)	Send a message to the default exchange with the supplied routing key.
CompletableFuture<Message>	AsyncAmqpTemplate.sendAndReceive(Message message)	Send a message to the default exchange with the default routing key.

Method parameters in org.springframework.amqp.core with type arguments of type Message

Modifier and Type	Method	Description
void	BatchMessageListener.onMessageBatch(List<Message> messages)
default void	MessageListener.onMessageBatch(List<Message> messages)	Delivers a batch of messages.

Constructors in org.springframework.amqp.core with parameters of type Message

Modifier	Constructor	Description
	AmqpReplyTimeoutException(String message, Message requestMessage)
	ReturnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey)

Uses of Message in org.springframework.amqp.rabbit

Subclasses with type arguments of type Message in org.springframework.amqp.rabbit

Modifier and Type	Class	Description
class	RabbitMessageFuture	A RabbitFuture with a return type of Message.

Methods in org.springframework.amqp.rabbit with parameters of type Message

Modifier and Type	Method	Description
void	AsyncRabbitTemplate.onMessage(Message message, @Nullable com.rabbitmq.client.Channel channel)
RabbitMessageFuture	AsyncRabbitTemplate.sendAndReceive(@Nullable String exchange, @Nullable String routingKey, Message message)
RabbitMessageFuture	AsyncRabbitTemplate.sendAndReceive(@Nullable String routingKey, Message message)
RabbitMessageFuture	AsyncRabbitTemplate.sendAndReceive(Message message)

Constructors in org.springframework.amqp.rabbit with parameters of type Message

Modifier	Constructor	Description
protected	RabbitFuture(String correlationId, Message requestMessage, BiConsumer<String, @Nullable DirectReplyToMessageListenerContainer.ChannelHolder> canceler, Function<RabbitFuture<?>, @Nullable ScheduledFuture<?>> timeoutTaskFunction)

Uses of Message in org.springframework.amqp.rabbit.batch

Methods in org.springframework.amqp.rabbit.batch that return Message

Modifier and Type	Method	Description
Message	MessageBatch.getMessage()	Deprecated, for removal: This API element is subject to removal in a future version. in favor or MessageBatch.message() ()}.
Message	MessageBatch.message()	Returns the value of the message record component.

Methods in org.springframework.amqp.rabbit.batch with parameters of type Message

Modifier and Type	Method	Description
@Nullable MessageBatch	BatchingStrategy.addToBatch(@Nullable String exchange, @Nullable String routingKey, Message message)	Add a message to the batch and optionally release the batch.
@Nullable MessageBatch	SimpleBatchingStrategy.addToBatch(@Nullable String exch, @Nullable String routKey, Message message)
default void	BatchingStrategy.deBatch(Message message, Consumer<Message> fragmentConsumer)	Decode a message into fragments.
void	SimpleBatchingStrategy.deBatch(Message message, Consumer<Message> fragmentConsumer)	Debatch a message that has a header with MessageProperties.SPRING_BATCH_FORMAT set to MessageProperties.BATCH_FORMAT_LENGTH_HEADER4.

Method parameters in org.springframework.amqp.rabbit.batch with type arguments of type Message

Modifier and Type	Method	Description
default void	BatchingStrategy.deBatch(Message message, Consumer<Message> fragmentConsumer)	Decode a message into fragments.
void	SimpleBatchingStrategy.deBatch(Message message, Consumer<Message> fragmentConsumer)	Debatch a message that has a header with MessageProperties.SPRING_BATCH_FORMAT set to MessageProperties.BATCH_FORMAT_LENGTH_HEADER4.

Constructors in org.springframework.amqp.rabbit.batch with parameters of type Message

Modifier	Constructor	Description
	MessageBatch(@Nullable String exchange, @Nullable String routingKey, Message message)	Creates an instance of a MessageBatch record class.

Uses of Message in org.springframework.amqp.rabbit.core

Methods in org.springframework.amqp.rabbit.core that return Message

Modifier and Type	Method	Description
protected Message	RabbitTemplate.convertMessageIfNecessary(Object object)
protected @Nullable Message	RabbitTemplate.convertSendAndReceiveRaw(@Nullable String exchange, @Nullable String routingKey, Object message, @Nullable MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationData)	Convert and send a message and return the raw reply message, or null.
protected @Nullable Message	RabbitTemplate.doReceiveNoWait(String queueName)	Non-blocking receive.
protected @Nullable Message	RabbitTemplate.doSendAndReceive(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)	Send a message and wait for a reply.
protected @Nullable Message	RabbitTemplate.doSendAndReceiveWithFixed(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
protected @Nullable Message	RabbitTemplate.doSendAndReceiveWithTemporary(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
Message	AmqpNackReceivedException.getFailedMessage()	Return the failed message.
@Nullable Message	RabbitTemplate.receive()
@Nullable Message	RabbitTemplate.receive(long timeoutMillis)
@Nullable Message	RabbitTemplate.receive(String queueName)
@Nullable Message	RabbitTemplate.receive(String queueName, long timeoutMillis)
@Nullable Message	RabbitTemplate.sendAndReceive(@Nullable String exchange, @Nullable String routingKey, Message message)
@Nullable Message	RabbitTemplate.sendAndReceive(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
@Nullable Message	RabbitTemplate.sendAndReceive(@Nullable String routingKey, Message message)
@Nullable Message	RabbitTemplate.sendAndReceive(@Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
@Nullable Message	RabbitTemplate.sendAndReceive(Message message)
@Nullable Message	RabbitTemplate.sendAndReceive(Message message, @Nullable CorrelationData correlationData)

Methods in org.springframework.amqp.rabbit.core with parameters of type Message

Modifier and Type	Method	Description
protected @Nullable Message<?>	RabbitMessagingTemplate.convertAmqpMessage(@Nullable Message message)
void	RabbitTemplate.doSend(com.rabbitmq.client.Channel channel, @Nullable String exchangeArg, @Nullable String routingKeyArg, Message message, boolean mandatory, @Nullable CorrelationData correlationData)	Send the given message to the specified exchange.
protected @Nullable Message	RabbitTemplate.doSendAndReceive(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)	Send a message and wait for a reply.
protected @Nullable Message	RabbitTemplate.doSendAndReceiveWithFixed(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
protected @Nullable Message	RabbitTemplate.doSendAndReceiveWithTemporary(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
Boolean	RabbitTemplate.isMandatoryFor(Message message)	Return whether the provided message should be sent with the mandatory flag set.
protected void	RabbitTemplate.logReceived(String prefix, @Nullable Message message)	Log a received message.
protected void	RabbitTemplate.observeTheSend(com.rabbitmq.client.Channel channel, Message message, boolean mandatory, String exch, String rKey)
void	BrokerEventListener.onMessage(Message message)
void	RabbitTemplate.onMessage(Message message, @Nullable com.rabbitmq.client.Channel channel)
CorrelationData	CorrelationDataPostProcessor.postProcess(Message message, @Nullable CorrelationData correlationData)	Update or replace the correlation data provided in the send method.
void	BatchingRabbitTemplate.send(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
void	RabbitOperations.send(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)	Send a message to a specific exchange with a specific routing key.
default void	RabbitOperations.send(@Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)	Send a message to the default exchange with a specific routing key.
void	RabbitTemplate.send(@Nullable String exchange, @Nullable String routingKey, Message message)
void	RabbitTemplate.send(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
void	RabbitTemplate.send(@Nullable String routingKey, Message message)
void	RabbitTemplate.send(@Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
void	RabbitTemplate.send(Message message)
@Nullable Message	RabbitTemplate.sendAndReceive(@Nullable String exchange, @Nullable String routingKey, Message message)
@Nullable Message	RabbitTemplate.sendAndReceive(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
@Nullable Message	RabbitTemplate.sendAndReceive(@Nullable String routingKey, Message message)
@Nullable Message	RabbitTemplate.sendAndReceive(@Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
@Nullable Message	RabbitTemplate.sendAndReceive(Message message)
@Nullable Message	RabbitTemplate.sendAndReceive(Message message, @Nullable CorrelationData correlationData)
protected void	RabbitTemplate.sendToRabbit(com.rabbitmq.client.Channel channel, String exchange, String routingKey, boolean mandatory, Message message)

Constructors in org.springframework.amqp.rabbit.core with parameters of type Message

Modifier	Constructor	Description
	AmqpNackReceivedException(String message, Message failedMessage)	Create an instance with the provided message and failed message.

Uses of Message in org.springframework.amqp.rabbit.listener

Methods in org.springframework.amqp.rabbit.listener that return Message

Modifier and Type	Method	Description
@Nullable Message	BlockingQueueConsumer.nextMessage()	Main application-side API: wait for the next message delivery and return it.
@Nullable Message	BlockingQueueConsumer.nextMessage(long timeout)	Main application-side API: wait for the next message delivery and return it.

Methods in org.springframework.amqp.rabbit.listener that return types with arguments of type Message

Modifier and Type	Method	Description
protected @Nullable List<Message>	AbstractMessageListenerContainer.debatch(Message message)

Methods in org.springframework.amqp.rabbit.listener with parameters of type Message

Modifier and Type	Method	Description
protected @Nullable List<Message>	AbstractMessageListenerContainer.debatch(Message message)
protected void	ConditionalRejectingErrorHandler.handleDiscarded(Message failed)	Called when a message with a fatal exception has an x-death header, prior to discarding the message.

Uses of Message in org.springframework.amqp.rabbit.listener.adapter

Subinterfaces with type arguments of type Message in org.springframework.amqp.rabbit.listener.adapter

Modifier and Type	Interface	Description
interface	ReplyPostProcessor	A post processor for replies.
interface	ReplyPostProcessor	A post processor for replies.
interface	ReplyPostProcessor	A post processor for replies.

Methods in org.springframework.amqp.rabbit.listener.adapter that return Message

Modifier and Type	Method	Description
protected Message	AbstractAdaptableMessageListener.buildMessage(@Nullable com.rabbitmq.client.Channel channel, @Nullable Object result, @Nullable Type genericType)	Build a Rabbit message to be sent as a response based on the given result object.
protected Message	MessagingMessageListenerAdapter.buildMessage(@Nullable com.rabbitmq.client.Channel channel, @Nullable Object result, @Nullable Type genericType)	Build a Rabbit message to be sent as response based on the given result object.
protected Message	AbstractAdaptableMessageListener.convert(@Nullable Object result, @Nullable Type genericType, MessageConverter converter)	Convert to a message with a reply content type based on settings.
Message	AbstractAdaptableMessageListener.ReplyExpressionRoot.request()	Returns the value of the request record component.

Methods in org.springframework.amqp.rabbit.listener.adapter with parameters of type Message

Modifier and Type	Method	Description
protected void	AbstractAdaptableMessageListener.asyncFailure(Message request, @Nullable com.rabbitmq.client.Channel channel, Throwable t, @Nullable Object source)
protected void	MessagingMessageListenerAdapter.asyncFailure(Message request, @Nullable com.rabbitmq.client.Channel channel, Throwable t, @Nullable Object source)
protected void	AbstractAdaptableMessageListener.basicAck(Message request, @Nullable com.rabbitmq.client.Channel channel)
protected Object[]	MessageListenerAdapter.buildListenerArguments(Object extractedMessage, @Nullable com.rabbitmq.client.Channel channel, Message message)	Build an array of arguments to be passed into the target listener method.
protected void	AbstractAdaptableMessageListener.doHandleResult(InvocationResult resultArg, Message request, @Nullable com.rabbitmq.client.Channel channel, @Nullable Object source)
protected void	AbstractAdaptableMessageListener.doPublish(com.rabbitmq.client.Channel channel, Address replyTo, Message message)
protected Object	AbstractAdaptableMessageListener.extractMessage(Message message)	Extract the message body from the given Rabbit message.
protected Object	MessagingMessageListenerAdapter.MessagingMessageConverterAdapter.extractPayload(Message message)
protected String	MessageListenerAdapter.getListenerMethodName(Message originalMessage, Object extractedMessage)	Determine the name of the listener method that will handle the given message.
protected @Nullable String	AbstractAdaptableMessageListener.getReceivedExchange(Message request)
protected Address	AbstractAdaptableMessageListener.getReplyToAddress(Message request, @Nullable Object source, InvocationResult result)	Determine a reply-to Address for the given message.
protected void	MessagingMessageListenerAdapter.handleException(Message amqpMessage, @Nullable com.rabbitmq.client.Channel channel, @Nullable Message<?> message, ListenerExecutionFailedException e)
protected void	AbstractAdaptableMessageListener.handleResult(@Nullable InvocationResult resultArg, Message request, @Nullable com.rabbitmq.client.Channel channel, @Nullable Object source)	Handle the given result object returned from the listener method, sending a response message back.
protected void	AbstractAdaptableMessageListener.handleResult(InvocationResult resultArg, Message request, @Nullable com.rabbitmq.client.Channel channel)	Handle the given result object returned from the listener method, sending a response message back.
protected InvocationResult	MessagingMessageListenerAdapter.invokeHandler(@Nullable com.rabbitmq.client.Channel channel, Message<?> message, boolean batch, Message... amqpMessages)	Invoke the handler, wrapping any exception to a ListenerExecutionFailedException with a dedicated error message.
protected void	MessagingMessageListenerAdapter.invokeHandlerAndProcessResult(Message amqpMessage, @Nullable com.rabbitmq.client.Channel channel, Message<?> message)
protected @Nullable Object	MessageListenerAdapter.invokeListenerMethod(String methodName, @Nullable Object @Nullable [] arguments, Message originalMessage)	Invoke the specified listener method.
void	MessageListenerAdapter.onMessage(Message message, @Nullable com.rabbitmq.client.Channel channel)	Spring ChannelAwareMessageListener entry point.
void	MessagingMessageListenerAdapter.onMessage(Message amqpMessage, @Nullable com.rabbitmq.client.Channel channel)
protected void	AbstractAdaptableMessageListener.postProcessChannel(com.rabbitmq.client.Channel channel, Message response)	Post-process the given message before sending the response.
protected void	AbstractAdaptableMessageListener.postProcessResponse(Message request, Message response)	Post-process the given response message before it will be sent.
protected void	AbstractAdaptableMessageListener.sendResponse(@Nullable com.rabbitmq.client.Channel channel, Address replyTo, Message messageIn)	Send the given response message to the given destination.
protected Message<?>	BatchMessagingMessageListenerAdapter.toMessagingMessage(Message amqpMessage)
protected Message<?>	MessagingMessageListenerAdapter.toMessagingMessage(Message amqpMessage)

Method parameters in org.springframework.amqp.rabbit.listener.adapter with type arguments of type Message

Modifier and Type	Method	Description
void	BatchMessagingMessageListenerAdapter.onMessageBatch(List<Message> messages, @Nullable com.rabbitmq.client.Channel channel)

Constructors in org.springframework.amqp.rabbit.listener.adapter with parameters of type Message

Modifier	Constructor	Description
	ReplyExpressionRoot(Message request, @Nullable Object source, @Nullable Object result)	Creates an instance of a ReplyExpressionRoot record class.

Uses of Message in org.springframework.amqp.rabbit.listener.api

Methods in org.springframework.amqp.rabbit.listener.api with parameters of type Message

Modifier and Type	Method	Description
@Nullable Object	RabbitListenerErrorHandler.handleError(Message amqpMessage, @Nullable com.rabbitmq.client.Channel channel, @Nullable Message<?> message, ListenerExecutionFailedException exception)	Handle the error.
default void	ChannelAwareBatchMessageListener.onMessage(Message message, @Nullable com.rabbitmq.client.Channel channel)
default void	ChannelAwareMessageListener.onMessage(Message message)
void	ChannelAwareMessageListener.onMessage(Message message, @Nullable com.rabbitmq.client.Channel channel)	Callback for processing a received Rabbit message.

Method parameters in org.springframework.amqp.rabbit.listener.api with type arguments of type Message

Modifier and Type	Method	Description
void	ChannelAwareBatchMessageListener.onMessageBatch(List<Message> messages, @Nullable com.rabbitmq.client.Channel channel)
default void	ChannelAwareMessageListener.onMessageBatch(List<Message> messages, @Nullable com.rabbitmq.client.Channel channel)

Uses of Message in org.springframework.amqp.rabbit.log4j2

Methods in org.springframework.amqp.rabbit.log4j2 that return Message

Modifier and Type	Method	Description
protected Message	AmqpAppender.postProcessMessageBeforeSend(Message message, AmqpAppender.Event event)	Subclasses may modify the final message before sending.

Methods in org.springframework.amqp.rabbit.log4j2 with parameters of type Message

Modifier and Type	Method	Description
protected Message	AmqpAppender.postProcessMessageBeforeSend(Message message, AmqpAppender.Event event)	Subclasses may modify the final message before sending.

Uses of Message in org.springframework.amqp.rabbit.logback

Methods in org.springframework.amqp.rabbit.logback that return Message

Modifier and Type	Method	Description
protected Message	AmqpAppender.postProcessMessageBeforeSend(Message message, AmqpAppender.Event event)	Subclasses may modify the final message before sending.

Methods in org.springframework.amqp.rabbit.logback with parameters of type Message

Modifier and Type	Method	Description
protected Message	AmqpAppender.postProcessMessageBeforeSend(Message message, AmqpAppender.Event event)	Subclasses may modify the final message before sending.

Uses of Message in org.springframework.amqp.rabbit.retry

Methods in org.springframework.amqp.rabbit.retry with parameters of type Message

Modifier and Type	Method	Description
protected @Nullable Map<? extends String, ?>	RepublishMessageRecoverer.additionalHeaders(Message message, @Nullable Throwable cause)	Subclasses can override this method to add more headers to the republished message.
protected void	RepublishMessageRecoverer.doSend(@Nullable String exchange, String routingKey, Message message)	Send the message.
protected void	RepublishMessageRecovererWithConfirms.doSend(@Nullable String exchange, String routingKey, Message message)
@Nullable Object	MessageKeyGenerator.getKey(Message message)	Generate a unique key for the message that is repeatable on redelivery.
boolean	NewMessageIdentifier.isNew(Message message)	Query a message to see if it has been seen before.
protected String	RepublishMessageRecoverer.prefixedOriginalRoutingKey(Message message)	The default behavior of this method is to append the received routing key to the routingKeyPrefix.
void	ImmediateRequeueMessageRecoverer.recover(Message message, @Nullable Throwable cause)
default void	MessageBatchRecoverer.recover(Message message, Throwable cause)
void	MessageRecoverer.recover(Message message, Throwable cause)	Callback for a message that was consumed but failed all retry attempts.
void	RejectAndDontRequeueRecoverer.recover(Message message, @Nullable Throwable cause)
void	RepublishMessageRecoverer.recover(Message message, @Nullable Throwable cause)

Method parameters in org.springframework.amqp.rabbit.retry with type arguments of type Message

Modifier and Type	Method	Description
void	MessageBatchRecoverer.recover(List<Message> messages, Throwable cause)	Callback for a message batch that was consumed but failed all retry attempts.

Uses of Message in org.springframework.amqp.rabbit.support

Methods in org.springframework.amqp.rabbit.support that return Message

Modifier and Type	Method	Description
@Nullable Message	ListenerExecutionFailedException.getFailedMessage()

Methods in org.springframework.amqp.rabbit.support that return types with arguments of type Message

Modifier and Type	Method	Description
Collection<Message>	ListenerExecutionFailedException.getFailedMessages()

Constructors in org.springframework.amqp.rabbit.support with parameters of type Message

Modifier	Constructor	Description
	ListenerExecutionFailedException(String msg, Throwable cause, Message... failedMessage)	Constructor for ListenerExecutionFailedException.

Uses of Message in org.springframework.amqp.rabbit.support.micrometer

Subclasses with type arguments of type Message in org.springframework.amqp.rabbit.support.micrometer

Modifier and Type	Class	Description
class	RabbitMessageReceiverContext	ReceiverContext for Messages.
class	RabbitMessageSenderContext	SenderContext for Messages.

Methods in org.springframework.amqp.rabbit.support.micrometer that return Message

Modifier and Type	Method	Description
Message	RabbitMessageReceiverContext.getCarrier()

Constructors in org.springframework.amqp.rabbit.support.micrometer with parameters of type Message

Modifier	Constructor	Description
	RabbitMessageReceiverContext(Message message, String listenerId)
	RabbitMessageSenderContext(Message message, String beanName, String exchange, String routingKey)	Create an instance RabbitMessageSenderContext.

Uses of Message in org.springframework.amqp.rabbit.test

Methods in org.springframework.amqp.rabbit.test that return Message

Modifier and Type	Method	Description
protected @Nullable Message	TestRabbitTemplate.doSendAndReceiveWithFixed(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)

Methods in org.springframework.amqp.rabbit.test with parameters of type Message

Modifier and Type	Method	Description
protected @Nullable Message	TestRabbitTemplate.doSendAndReceiveWithFixed(@Nullable String exchange, @Nullable String routingKey, Message message, @Nullable CorrelationData correlationData)
protected void	TestRabbitTemplate.sendToRabbit(com.rabbitmq.client.Channel channel, String exchange, String routingKey, boolean mandatory, Message message)

Uses of Message in org.springframework.amqp.rabbitmq.client

Methods in org.springframework.amqp.rabbitmq.client that return Message

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

Methods in org.springframework.amqp.rabbitmq.client that return types with arguments of type Message

Modifier and Type	Method	Description
CompletableFuture<Message>	RabbitAmqpTemplate.receive()
CompletableFuture<Message>	RabbitAmqpTemplate.receive(String queueName)	Request a head message from the provided queue.
CompletableFuture<Message>	RabbitAmqpTemplate.sendAndReceive(String exchange, @Nullable String routingKey, Message message)
CompletableFuture<Message>	RabbitAmqpTemplate.sendAndReceive(String queue, Message message)
CompletableFuture<Message>	RabbitAmqpTemplate.sendAndReceive(Message message)

Methods in org.springframework.amqp.rabbitmq.client with parameters of type Message

Modifier and Type	Method	Description
CompletableFuture<Boolean>	RabbitAmqpTemplate.send(String exchange, @Nullable String routingKey, Message message)
CompletableFuture<Boolean>	RabbitAmqpTemplate.send(String queue, Message message)	Publish the message to the provided queue.
CompletableFuture<Boolean>	RabbitAmqpTemplate.send(Message message)	Publish a message to the default exchange and routing key (if any) (or queue) configured on this template.
CompletableFuture<Message>	RabbitAmqpTemplate.sendAndReceive(String exchange, @Nullable String routingKey, Message message)
CompletableFuture<Message>	RabbitAmqpTemplate.sendAndReceive(String queue, Message message)
CompletableFuture<Message>	RabbitAmqpTemplate.sendAndReceive(Message message)
static void	RabbitAmqpUtils.toAmqpMessage(Message message, com.rabbitmq.client.amqp.Message amqpMessage)	Convert Message into Message.

Uses of Message in org.springframework.amqp.rabbitmq.client.listener

Methods in org.springframework.amqp.rabbitmq.client.listener with parameters of type Message

Modifier and Type	Method	Description
protected void	RabbitAmqpMessageListenerAdapter.asyncFailure(Message request, @Nullable com.rabbitmq.client.Channel channel, Throwable t, @Nullable Object source)
protected void	RabbitAmqpMessageListenerAdapter.basicAck(Message request, @Nullable com.rabbitmq.client.Channel channel)
protected void	RabbitAmqpMessageListenerAdapter.sendResponse(@Nullable com.rabbitmq.client.Channel channel, Address replyTo, Message messageIn)

Method parameters in org.springframework.amqp.rabbitmq.client.listener with type arguments of type Message

Modifier and Type	Method	Description
void	RabbitAmqpMessageListenerAdapter.onMessageBatch(List<Message> messages)

Uses of Message in org.springframework.amqp.support.converter

Methods in org.springframework.amqp.support.converter that return Message

Modifier and Type	Method	Description
protected Message	AbstractJackson2MessageConverter.createMessage(Object objectToConvert, MessageProperties messageProperties)	Deprecated, for removal: This API element is subject to removal in a future version.
protected Message	AbstractJackson2MessageConverter.createMessage(Object objectToConvert, MessageProperties messageProperties, @Nullable Type genericType)	Deprecated, for removal: This API element is subject to removal in a future version.
protected Message	AbstractJacksonMessageConverter.createMessage(Object objectToConvert, MessageProperties messageProperties)
protected Message	AbstractJacksonMessageConverter.createMessage(Object objectToConvert, MessageProperties messageProperties, @Nullable Type genericType)
protected abstract Message	AbstractMessageConverter.createMessage(Object object, MessageProperties messageProperties)	Crate a message from the payload object and message properties provided.
protected Message	AbstractMessageConverter.createMessage(Object object, MessageProperties messageProperties, @Nullable Type genericType)	Crate a message from the payload object and message properties provided.
protected Message	MarshallingMessageConverter.createMessage(Object object, MessageProperties messageProperties)	Marshals the given object to a Message.
protected Message	SerializerMessageConverter.createMessage(Object object, MessageProperties messageProperties)	Creates an AMQP Message from the provided Object.
protected Message	SimpleMessageConverter.createMessage(Object object, MessageProperties messageProperties)	Creates an AMQP Message from the provided Object.
final Message	AbstractMessageConverter.toMessage(Object object, @Nullable MessageProperties messagePropertiesArg, @Nullable Type genericType)
final Message	AbstractMessageConverter.toMessage(Object object, MessageProperties messageProperties)
Message	ContentTypeDelegatingMessageConverter.toMessage(Object object, MessageProperties messageProperties)
Message	MessageConverter.toMessage(Object object, MessageProperties messageProperties)	Convert a Java object to a Message.
default Message	MessageConverter.toMessage(Object object, MessageProperties messageProperties, @Nullable Type genericType)	Convert a Java object to a Message.
Message	MessagingMessageConverter.toMessage(Object object, MessageProperties messageProperties)
Message	RemoteInvocationAwareMessageConverterAdapter.toMessage(Object object, MessageProperties messageProperties)

Methods in org.springframework.amqp.support.converter with parameters of type Message

Modifier and Type	Method	Description
Object	JacksonProjectingMessageConverter.convert(Message message, Type type)
Object	ProjectingMessageConverter.convert(Message message, Type type)	Deprecated, for removal: This API element is subject to removal in a future version.
protected Object	AbstractJacksonMessageConverter.convertContent(Message message, @Nullable Object conversionHint, MessageProperties properties, @Nullable String encoding)
protected Object	JacksonJsonMessageConverter.convertContent(Message message, @Nullable Object conversionHint, MessageProperties properties, @Nullable String encoding)
protected Object	AbstractJacksonMessageConverter.doFromMessage(Message message, @Nullable Object conversionHint, MessageProperties properties, @Nullable String encoding)
protected Object	MessagingMessageConverter.extractPayload(Message message)	Extract the payload of the specified Message.
Object	AbstractJackson2MessageConverter.fromMessage(Message message)	Deprecated, for removal: This API element is subject to removal in a future version.
Object	AbstractJackson2MessageConverter.fromMessage(Message message, @Nullable Object conversionHint)	Deprecated, for removal: This API element is subject to removal in a future version. A variant of MessageConverter.fromMessage(Message) which takes an extra conversion context as an argument.
Object	AbstractJacksonMessageConverter.fromMessage(Message message)
Object	AbstractJacksonMessageConverter.fromMessage(Message message, @Nullable Object conversionHint)	A variant of MessageConverter.fromMessage(Message) which takes an extra conversion context as an argument.
Object	ContentTypeDelegatingMessageConverter.fromMessage(Message message)
Object	MarshallingMessageConverter.fromMessage(Message message)	Unmarshals the given Message into an object.
Object	MessageConverter.fromMessage(Message message)	Convert from a Message to a Java object.
Object	MessagingMessageConverter.fromMessage(Message message)
Object	RemoteInvocationAwareMessageConverterAdapter.fromMessage(Message message)
Object	SerializerMessageConverter.fromMessage(Message message)	Converts from a AMQP Message to an Object.
Object	SimpleMessageConverter.fromMessage(Message message)	Converts from a AMQP Message to an Object.
Object	SmartMessageConverter.fromMessage(Message message, @Nullable Object conversionHint)	A variant of MessageConverter.fromMessage(Message) which takes an extra conversion context as an argument.

Uses of Message in org.springframework.amqp.support.postprocessor

Methods in org.springframework.amqp.support.postprocessor that return Message

Modifier and Type	Method	Description
Message	AbstractCompressingPostProcessor.postProcessMessage(Message message)
Message	AbstractDecompressingPostProcessor.postProcessMessage(Message message)
Message	DelegatingDecompressingPostProcessor.postProcessMessage(Message message)

Methods in org.springframework.amqp.support.postprocessor with parameters of type Message

Modifier and Type	Method	Description
Message	AbstractCompressingPostProcessor.postProcessMessage(Message message)
Message	AbstractDecompressingPostProcessor.postProcessMessage(Message message)
Message	DelegatingDecompressingPostProcessor.postProcessMessage(Message message)

Uses of Message in org.springframework.rabbit.stream.producer

Methods in org.springframework.rabbit.stream.producer with parameters of type Message

Modifier and Type	Method	Description
CompletableFuture<Boolean>	RabbitStreamOperations.send(Message message)	Send a Spring AMQP message.
CompletableFuture<Boolean>	RabbitStreamTemplate.send(Message message)

Uses of Message in org.springframework.rabbit.stream.retry

Methods in org.springframework.rabbit.stream.retry with parameters of type Message

Modifier and Type	Method	Description
default void	StreamMessageRecoverer.recover(Message message, @Nullable Throwable cause)

Uses of Message in org.springframework.rabbit.stream.support.converter

Methods in org.springframework.rabbit.stream.support.converter that return Message

Modifier and Type	Method	Description
Message	DefaultStreamMessageConverter.toMessage(Object object, StreamMessageProperties messageProperties)
default Message	StreamMessageConverter.toMessage(Object object, MessageProperties messageProperties)
Message	StreamMessageConverter.toMessage(Object object, StreamMessageProperties messageProperties)

Methods in org.springframework.rabbit.stream.support.converter with parameters of type Message

Modifier and Type	Method	Description
com.rabbitmq.stream.Message	DefaultStreamMessageConverter.fromMessage(Message message)
com.rabbitmq.stream.Message	StreamMessageConverter.fromMessage(Message message)