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.support	Package for Spring AMQP support classes.
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

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, Correlation correlation)	Change (or replace) the message and/or change its correlation data.
default Message	MessagePostProcessor.postProcessMessage(Message message, Correlation correlation, String exchange, String routingKey)	Change (or replace) the message and/or change its correlation data.
Message	AmqpTemplate.receive()	Receive a message if there is one from a default queue.
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.
Message	AmqpTemplate.receive(String queueName)	Receive a message if there is one from a specific queue.
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.
Message	AmqpTemplate.sendAndReceive(String exchange, String routingKey, Message message)	Basic RPC pattern.
Message	AmqpTemplate.sendAndReceive(String routingKey, Message message)	Basic RPC pattern.
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
CompletableFuture<Message>	AsyncAmqpTemplate.sendAndReceive(String exchange, 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, Correlation correlation)	Change (or replace) the message and/or change its correlation data.
default Message	MessagePostProcessor.postProcessMessage(Message message, 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.
Message	AmqpTemplate.sendAndReceive(String exchange, String routingKey, Message message)	Basic RPC pattern.
Message	AmqpTemplate.sendAndReceive(String routingKey, Message message)	Basic RPC pattern.
Message	AmqpTemplate.sendAndReceive(Message message)	Basic RPC pattern.
CompletableFuture<Message>	AsyncAmqpTemplate.sendAndReceive(String exchange, 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

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

Modifier and Type	Method	Description
void	AsyncRabbitTemplate.onMessage(Message message, com.rabbitmq.client.Channel channel)
RabbitMessageFuture	AsyncRabbitTemplate.sendAndReceive(String exchange, String routingKey, Message message)
RabbitMessageFuture	AsyncRabbitTemplate.sendAndReceive(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,DirectReplyToMessageListenerContainer.ChannelHolder> canceler, Function<RabbitFuture<?>,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()

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

Modifier and Type	Method	Description
MessageBatch	BatchingStrategy.addToBatch(String exchange, String routingKey, Message message)	Add a message to the batch and optionally release the batch.
MessageBatch	SimpleBatchingStrategy.addToBatch(String exch, 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(String exchange, String routingKey, Message message)

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 Message	RabbitTemplate.convertSendAndReceiveRaw(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData)	Convert and send a message and return the raw reply message, or null.
protected Message	RabbitTemplate.doReceiveNoWait(String queueName)	Non-blocking receive.
protected Message	RabbitTemplate.doSendAndReceive(String exchange, String routingKey, Message message, CorrelationData correlationData)	Send a message and wait for a reply.
protected Message	RabbitTemplate.doSendAndReceiveWithFixed(String exchange, String routingKey, Message message, CorrelationData correlationData)
protected Message	RabbitTemplate.doSendAndReceiveWithTemporary(String exchange, String routingKey, Message message, CorrelationData correlationData)
Message	AmqpNackReceivedException.getFailedMessage()	Return the failed message.
Message	RabbitTemplate.receive()
Message	RabbitTemplate.receive(long timeoutMillis)
Message	RabbitTemplate.receive(String queueName)
Message	RabbitTemplate.receive(String queueName, long timeoutMillis)
Message	RabbitTemplate.sendAndReceive(String exchange, String routingKey, Message message)
Message	RabbitTemplate.sendAndReceive(String exchange, String routingKey, Message message, CorrelationData correlationData)
Message	RabbitTemplate.sendAndReceive(String routingKey, Message message)
Message	RabbitTemplate.sendAndReceive(String routingKey, Message message, CorrelationData correlationData)
Message	RabbitTemplate.sendAndReceive(Message message)
Message	RabbitTemplate.sendAndReceive(Message message, CorrelationData correlationData)

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

Modifier and Type	Method	Description
protected Message<?>	RabbitMessagingTemplate.convertAmqpMessage(Message message)
void	RabbitTemplate.doSend(com.rabbitmq.client.Channel channel, String exchangeArg, String routingKeyArg, Message message, boolean mandatory, CorrelationData correlationData)	Send the given message to the specified exchange.
protected Message	RabbitTemplate.doSendAndReceive(String exchange, String routingKey, Message message, CorrelationData correlationData)	Send a message and wait for a reply.
protected Message	RabbitTemplate.doSendAndReceiveWithFixed(String exchange, String routingKey, Message message, CorrelationData correlationData)
protected Message	RabbitTemplate.doSendAndReceiveWithTemporary(String exchange, String routingKey, Message message, 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, 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, com.rabbitmq.client.Channel channel)
CorrelationData	CorrelationDataPostProcessor.postProcess(Message message, CorrelationData correlationData)	Update or replace the correlation data provided in the send method.
void	BatchingRabbitTemplate.send(String exchange, String routingKey, Message message, CorrelationData correlationData)
void	RabbitOperations.send(String exchange, String routingKey, Message message, CorrelationData correlationData)	Send a message to a specific exchange with a specific routing key.
default void	RabbitOperations.send(String routingKey, Message message, CorrelationData correlationData)	Send a message to the default exchange with a specific routing key.
void	RabbitTemplate.send(String exchange, String routingKey, Message message)
void	RabbitTemplate.send(String exchange, String routingKey, Message message, CorrelationData correlationData)
void	RabbitTemplate.send(String routingKey, Message message)
void	RabbitTemplate.send(String routingKey, Message message, CorrelationData correlationData)
void	RabbitTemplate.send(Message message)
Message	RabbitTemplate.sendAndReceive(String exchange, String routingKey, Message message)
Message	RabbitTemplate.sendAndReceive(String exchange, String routingKey, Message message, CorrelationData correlationData)
Message	RabbitTemplate.sendAndReceive(String routingKey, Message message)
Message	RabbitTemplate.sendAndReceive(String routingKey, Message message, CorrelationData correlationData)
Message	RabbitTemplate.sendAndReceive(Message message)
Message	RabbitTemplate.sendAndReceive(Message message, 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
Message	BlockingQueueConsumer.nextMessage()	Main application-side API: wait for the next message delivery and return it.
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 List<Message>	AbstractMessageListenerContainer.debatch(Message message)

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

Modifier and Type	Method	Description
protected 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

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

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

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

Modifier and Type	Method	Description
protected void	AbstractAdaptableMessageListener.asyncFailure(Message request, com.rabbitmq.client.Channel channel, Throwable t, Object source)
protected void	MessagingMessageListenerAdapter.asyncFailure(Message request, com.rabbitmq.client.Channel channel, Throwable t, Object source)
protected Object[]	MessageListenerAdapter.buildListenerArguments(Object extractedMessage, 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, com.rabbitmq.client.Channel channel, 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 String	AbstractAdaptableMessageListener.getReceivedExchange(Message request)
protected Address	AbstractAdaptableMessageListener.getReplyToAddress(Message request, Object source, InvocationResult result)	Determine a reply-to Address for the given message.
protected void	AbstractAdaptableMessageListener.handleResult(InvocationResult resultArg, Message request, com.rabbitmq.client.Channel channel)	Handle the given result object returned from the listener method, sending a response message back.
protected void	AbstractAdaptableMessageListener.handleResult(InvocationResult resultArg, Message request, com.rabbitmq.client.Channel channel, Object source)	Handle the given result object returned from the listener method, sending a response message back.
protected void	MessagingMessageListenerAdapter.invokeHandlerAndProcessResult(Message amqpMessage, com.rabbitmq.client.Channel channel, Message<?> message)
protected Object	MessageListenerAdapter.invokeListenerMethod(String methodName, Object[] arguments, Message originalMessage)	Invoke the specified listener method.
void	MessageListenerAdapter.onMessage(Message message, com.rabbitmq.client.Channel channel)	Spring ChannelAwareMessageListener entry point.
void	MessagingMessageListenerAdapter.onMessage(Message amqpMessage, 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(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, com.rabbitmq.client.Channel channel)

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

Modifier	Constructor	Description
protected	ReplyExpressionRoot(Message request, Object source, Object result)

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
default Object	RabbitListenerErrorHandler.handleError(Message amqpMessage, com.rabbitmq.client.Channel channel, Message<?> message, ListenerExecutionFailedException exception)	Handle the error.
Object	RabbitListenerErrorHandler.handleError(Message amqpMessage, Message<?> message, ListenerExecutionFailedException exception)	Deprecated, for removal: This API element is subject to removal in a future version. in favor of RabbitListenerErrorHandler.handleError(Message, Channel, org.springframework.messaging.Message, ListenerExecutionFailedException)
default void	ChannelAwareBatchMessageListener.onMessage(Message message, com.rabbitmq.client.Channel channel)
default void	ChannelAwareMessageListener.onMessage(Message message)
void	ChannelAwareMessageListener.onMessage(Message message, 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, com.rabbitmq.client.Channel channel)
default void	ChannelAwareMessageListener.onMessageBatch(List<Message> messages, 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 Map<? extends String,?>	RepublishMessageRecoverer.additionalHeaders(Message message, Throwable cause)	Subclasses can override this method to add more headers to the republished message.
protected void	RepublishMessageRecoverer.doSend(String exchange, String routingKey, Message message)	Send the message.
protected void	RepublishMessageRecovererWithConfirms.doSend(String exchange, String routingKey, Message message)
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, Throwable cause)
default void	MessageBatchRecoverer.recover(Message message, Throwable cause)
void	MessageRecoverer.recover(Message message, Throwable cause)	Callback for message that was consumed but failed all retry attempts.
void	RejectAndDontRequeueRecoverer.recover(Message message, Throwable cause)
void	RepublishMessageRecoverer.recover(Message message, 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 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
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

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 destination)

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 Message	TestRabbitTemplate.doSendAndReceiveWithFixed(String exchange, String routingKey, Message message, CorrelationData correlationData)

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

Modifier and Type	Method	Description
protected Message	TestRabbitTemplate.doSendAndReceiveWithFixed(String exchange, String routingKey, Message message, 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.support

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

Modifier and Type	Method	Description
static Message	SendRetryContextAccessor.getMessage(org.springframework.retry.RetryContext context)	Retrieve the Message from the context.

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)
protected Message	AbstractJackson2MessageConverter.createMessage(Object objectToConvert, MessageProperties messageProperties, 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, 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, MessageProperties messageProperties)
final Message	AbstractMessageConverter.toMessage(Object object, MessageProperties messagePropertiesArg, Type genericType)
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, 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	ProjectingMessageConverter.convert(Message message, Type type)
protected Object	MessagingMessageConverter.extractPayload(Message message)	Extract the payload of the specified Message.
Object	AbstractJackson2MessageConverter.fromMessage(Message message)
Object	AbstractJackson2MessageConverter.fromMessage(Message message, 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, 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, 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)