Uses of Class
org.springframework.amqp.core.Message
Packages that use Message
Package
Description
Provides core classes for the spring AMQP abstraction.
Provides top-level classes for Spring Rabbit.
Provides classes for message batching.
Provides classes related to connections.
Provides core classes for Spring Rabbit.
Provides classes for message listener containers.
Provides classes for adapting listeners.
Provides Additional APIs for listeners.
Provides classes supporting Log4j 2 appenders.
Provides classes supporting Logback appenders.
Provides classes supporting retries.
Provides support classes for Spring Rabbit.
Classes for testing Spring AMQP applications.
Package for Spring AMQP support classes.
Provides classes for supporting message conversion.
Package for Spring AMQP message post processors.
Provides classes for stream producers.
Provides classes for message conversion.
-
Uses of Message in org.springframework.amqp.core
Methods in org.springframework.amqp.core that return MessageModifier and TypeMethodDescriptionMessageBuilder.build()
ReturnedMessage.getMessage()
Get the message.AmqpReplyTimeoutException.getRequestMessage()
AmqpMessageReturnedException.getReturnedMessage()
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.AmqpTemplate.receive()
Receive a message if there is one from a default queue.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.Receive a message if there is one from a specific queue.Receive a message from a specific queue, waiting up to the specified wait time if necessary for a message to become available.AmqpTemplate.sendAndReceive
(String exchange, String routingKey, Message message) Basic RPC pattern.AmqpTemplate.sendAndReceive
(String routingKey, Message message) Basic RPC pattern.AmqpTemplate.sendAndReceive
(Message message) Basic RPC pattern.Methods in org.springframework.amqp.core that return types with arguments of type MessageModifier and TypeMethodDescriptionAsyncAmqpTemplate.sendAndReceive
(String exchange, String routingKey, Message message) Send a message to the supplied exchange and routing key.AsyncAmqpTemplate.sendAndReceive
(String routingKey, Message message) Send a message to the default exchange with the supplied routing key.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 MessageModifier and TypeMethodDescriptionstatic 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.ReplyToAddressCallback.getReplyToAddress
(Message request, T reply) default void
void
Delivers a single 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
Send a message to a specific exchange with a specific routing key.void
Send a message to a default exchange with a specific routing key.void
Send a message to a default exchange with a default routing key.AmqpTemplate.sendAndReceive
(String exchange, String routingKey, Message message) Basic RPC pattern.AmqpTemplate.sendAndReceive
(String routingKey, Message message) Basic RPC pattern.AmqpTemplate.sendAndReceive
(Message message) Basic RPC pattern.AsyncAmqpTemplate.sendAndReceive
(String exchange, String routingKey, Message message) Send a message to the supplied exchange and routing key.AsyncAmqpTemplate.sendAndReceive
(String routingKey, Message message) Send a message to the default exchange with the supplied routing key.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 MessageModifier and TypeMethodDescriptionvoid
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 MessageModifierConstructorDescriptionAmqpMessageReturnedException
(String message, Message returnedMessage, int replyCode, String replyText, String exchange, String routingKey) Deprecated.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 MessageModifier and TypeMethodDescriptionvoid
AsyncRabbitTemplate.sendAndReceive
(String exchange, String routingKey, Message message) AsyncRabbitTemplate.sendAndReceive
(String routingKey, Message message) AsyncRabbitTemplate.sendAndReceive
(Message message) Constructors in org.springframework.amqp.rabbit with parameters of type MessageModifierConstructorDescriptionRabbitConverterFuture
(String correlationId, Message requestMessage) RabbitFuture
(String correlationId, Message requestMessage) RabbitMessageFuture
(String correlationId, Message requestMessage) -
Uses of Message in org.springframework.amqp.rabbit.batch
Methods in org.springframework.amqp.rabbit.batch that return MessageMethods in org.springframework.amqp.rabbit.batch with parameters of type MessageModifier and TypeMethodDescriptionBatchingStrategy.addToBatch
(String exchange, String routingKey, Message message) Add a message to the batch and optionally release the batch.SimpleBatchingStrategy.addToBatch
(String exch, String routKey, Message message) default void
Decode a message into fragments.void
Debatch a message that has a header withMessageProperties.SPRING_BATCH_FORMAT
set toMessageProperties.BATCH_FORMAT_LENGTH_HEADER4
.Method parameters in org.springframework.amqp.rabbit.batch with type arguments of type MessageModifier and TypeMethodDescriptiondefault void
Decode a message into fragments.void
Debatch a message that has a header withMessageProperties.SPRING_BATCH_FORMAT
set toMessageProperties.BATCH_FORMAT_LENGTH_HEADER4
.Constructors in org.springframework.amqp.rabbit.batch with parameters of type Message -
Uses of Message in org.springframework.amqp.rabbit.connection
Methods in org.springframework.amqp.rabbit.connection that return MessageMethods in org.springframework.amqp.rabbit.connection with parameters of type MessageModifier and TypeMethodDescriptionvoid
CorrelationData.setReturnedMessage
(Message returnedMessage) Deprecated.in favor ofCorrelationData.setReturned(ReturnedMessage)
. -
Uses of Message in org.springframework.amqp.rabbit.core
Methods in org.springframework.amqp.rabbit.core that return MessageModifier and TypeMethodDescriptionprotected 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) AmqpNackReceivedException.getFailedMessage()
Return the failed message.RabbitTemplate.receive()
RabbitTemplate.receive
(long timeoutMillis) RabbitTemplate.sendAndReceive
(String exchange, String routingKey, Message message) RabbitTemplate.sendAndReceive
(String exchange, String routingKey, Message message, CorrelationData correlationData) RabbitTemplate.sendAndReceive
(String routingKey, Message message) RabbitTemplate.sendAndReceive
(String routingKey, Message message, CorrelationData correlationData) RabbitTemplate.sendAndReceive
(Message message) RabbitTemplate.sendAndReceive
(Message message, CorrelationData correlationData) Methods in org.springframework.amqp.rabbit.core with parameters of type MessageModifier and TypeMethodDescriptionprotected 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) RabbitTemplate.isMandatoryFor
(Message message) Return whether the provided message should be sent with the mandatory flag set.void
void
Deprecated.void
CorrelationDataPostProcessor.postProcess
(Message message, CorrelationData correlationData) Update or replace the correlation data provided in the send method.void
RabbitTemplate.ReturnCallback.returnedMessage
(Message message, int replyCode, String replyText, String exchange, String routingKey) Deprecated.Returned message callback.default void
RabbitTemplate.ReturnsCallback.returnedMessage
(Message message, int replyCode, String replyText, String exchange, String routingKey) Deprecated.in favor ofRabbitTemplate.ReturnsCallback.returnedMessage(ReturnedMessage)
which is easier to use with lambdas.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
void
RabbitTemplate.send
(String exchange, String routingKey, Message message, CorrelationData correlationData) void
void
RabbitTemplate.send
(String routingKey, Message message, CorrelationData correlationData) void
RabbitTemplate.sendAndReceive
(String exchange, String routingKey, Message message) RabbitTemplate.sendAndReceive
(String exchange, String routingKey, Message message, CorrelationData correlationData) RabbitTemplate.sendAndReceive
(String routingKey, Message message) RabbitTemplate.sendAndReceive
(String routingKey, Message message, CorrelationData correlationData) RabbitTemplate.sendAndReceive
(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 MessageModifierConstructorDescriptionAmqpNackReceivedException
(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 MessageModifier and TypeMethodDescriptionBlockingQueueConsumer.nextMessage()
Main application-side API: wait for the next message delivery and return it.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 MessageModifier and TypeMethodDescriptionMethods in org.springframework.amqp.rabbit.listener with parameters of type Message -
Uses of Message in org.springframework.amqp.rabbit.listener.adapter
Methods in org.springframework.amqp.rabbit.listener.adapter that return MessageModifier and TypeMethodDescriptionprotected 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.AbstractAdaptableMessageListener.ReplyExpressionRoot.getRequest()
Methods in org.springframework.amqp.rabbit.listener.adapter with parameters of type MessageModifier and TypeMethodDescriptionprotected 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
SpringChannelAwareMessageListener
entry point.void
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 MessageModifier and TypeMethodDescriptionvoid
BatchMessagingMessageListenerAdapter.onMessageBatch
(List<Message> messages, com.rabbitmq.client.Channel channel) Constructors in org.springframework.amqp.rabbit.listener.adapter with parameters of type MessageModifierConstructorDescriptionprotected
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 MessageModifier and TypeMethodDescriptionRabbitListenerErrorHandler.handleError
(Message amqpMessage, Message<?> message, ListenerExecutionFailedException exception) Handle the error.default void
default void
void
Callback for processing a received Rabbit message.Method parameters in org.springframework.amqp.rabbit.listener.api with type arguments of type MessageModifier and TypeMethodDescriptionvoid
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 MessageModifier and TypeMethodDescriptionprotected 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 MessageModifier and TypeMethodDescriptionprotected 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 MessageModifier and TypeMethodDescriptionprotected 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 MessageModifier and TypeMethodDescriptionprotected 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 MessageModifier and TypeMethodDescriptionRepublishMessageRecoverer.additionalHeaders
(Message message, Throwable cause) Subclasses can override this method to add more headers to the republished message.protected void
Send the message.protected void
Generate a unique key for the message that is repeatable on redelivery.boolean
Query a message to see if it has been seen before.void
default void
void
Callback for message that was consumed but failed all retry attempts.void
void
Method parameters in org.springframework.amqp.rabbit.retry with type arguments of type Message -
Uses of Message in org.springframework.amqp.rabbit.support
Methods in org.springframework.amqp.rabbit.support that return MessageMethods in org.springframework.amqp.rabbit.support that return types with arguments of type MessageConstructors in org.springframework.amqp.rabbit.support with parameters of type MessageModifierConstructorDescriptionListenerExecutionFailedException
(String msg, Throwable cause, Message... failedMessage) Constructor for ListenerExecutionFailedException. -
Uses of Message in org.springframework.amqp.rabbit.test
Methods in org.springframework.amqp.rabbit.test that return MessageModifier and TypeMethodDescriptionprotected Message
TestRabbitTemplate.doSendAndReceiveWithFixed
(String exchange, String routingKey, Message message, CorrelationData correlationData) Methods in org.springframework.amqp.rabbit.test with parameters of type MessageModifier and TypeMethodDescriptionprotected 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 MessageModifier and TypeMethodDescriptionstatic Message
SendRetryContextAccessor.getMessage
(org.springframework.retry.RetryContext context) Retrieve theMessage
from the context. -
Uses of Message in org.springframework.amqp.support.converter
Methods in org.springframework.amqp.support.converter that return MessageModifier and TypeMethodDescriptionprotected 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 aMessage
.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) ContentTypeDelegatingMessageConverter.toMessage
(Object object, MessageProperties messageProperties) 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.MessagingMessageConverter.toMessage
(Object object, MessageProperties messageProperties) RemoteInvocationAwareMessageConverterAdapter.toMessage
(Object object, MessageProperties messageProperties) Methods in org.springframework.amqp.support.converter with parameters of type MessageModifier and TypeMethodDescriptionprotected Object
MessagingMessageConverter.extractPayload
(Message message) Extract the payload of the specifiedMessage
.AbstractJackson2MessageConverter.fromMessage
(Message message) AbstractJackson2MessageConverter.fromMessage
(Message message, Object conversionHint) A variant ofMessageConverter.fromMessage(Message)
which takes an extra conversion context as an argument.ContentTypeDelegatingMessageConverter.fromMessage
(Message message) MarshallingMessageConverter.fromMessage
(Message message) Unmarshals the givenMessage
into an object.MessageConverter.fromMessage
(Message message) Convert from a Message to a Java object.MessagingMessageConverter.fromMessage
(Message message) RemoteInvocationAwareMessageConverterAdapter.fromMessage
(Message message) SerializerMessageConverter.fromMessage
(Message message) Converts from a AMQP Message to an Object.SimpleMessageConverter.fromMessage
(Message message) Converts from a AMQP Message to an Object.SmartMessageConverter.fromMessage
(Message message, Object conversionHint) A variant ofMessageConverter.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 MessageModifier and TypeMethodDescriptionAbstractCompressingPostProcessor.postProcessMessage
(Message message) AbstractDecompressingPostProcessor.postProcessMessage
(Message message) DelegatingDecompressingPostProcessor.postProcessMessage
(Message message) Methods in org.springframework.amqp.support.postprocessor with parameters of type MessageModifier and TypeMethodDescriptionAbstractCompressingPostProcessor.postProcessMessage
(Message message) AbstractDecompressingPostProcessor.postProcessMessage
(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 MessageModifier and TypeMethodDescriptionSend a Spring AMQP message. -
Uses of Message in org.springframework.rabbit.stream.support.converter
Methods in org.springframework.rabbit.stream.support.converter that return MessageModifier and TypeMethodDescriptionDefaultStreamMessageConverter.toMessage
(Object object, StreamMessageProperties messageProperties) default Message
StreamMessageConverter.toMessage
(Object object, MessageProperties messageProperties) StreamMessageConverter.toMessage
(Object object, StreamMessageProperties messageProperties) Methods in org.springframework.rabbit.stream.support.converter with parameters of type MessageModifier and TypeMethodDescriptioncom.rabbitmq.stream.Message
DefaultStreamMessageConverter.fromMessage
(Message message) com.rabbitmq.stream.Message
StreamMessageConverter.fromMessage
(Message message)
CorrelationData.getReturned()
.