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.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.retry	Provides classes supporting retries.
org.springframework.amqp.remoting.service	Provides classes for the service side of Spring Remoting over AMQP.
org.springframework.amqp.support.converter	Provides classes for supporting message conversion.

Uses of Message in org.springframework.amqp.core

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

Modifier and Type	Method and Description
Message	MessageBuilder.build()
Message	MessagePostProcessor.postProcessMessage(Message message)
Message	AmqpTemplate.receive() Receive a message if there is one from a default queue.
Message	AmqpTemplate.receive(java.lang.String queueName) Receive a message if there is one from a specific queue.
Message	AmqpTemplate.sendAndReceive(Message message) Basic RPC pattern.
Message	AmqpTemplate.sendAndReceive(java.lang.String routingKey, Message message) Basic RPC pattern.
Message	AmqpTemplate.sendAndReceive(java.lang.String exchange, java.lang.String routingKey, Message message) Basic RPC pattern.

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

Modifier and Type	Method and 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)
void	MessageListener.onMessage(Message message)
Message	MessagePostProcessor.postProcessMessage(Message message)
void	AmqpTemplate.send(Message message) Send a message to a default exchange with a default routing key.
void	AmqpTemplate.send(java.lang.String routingKey, Message message) Send a message to a default exchange with a specific routing key.
void	AmqpTemplate.send(java.lang.String exchange, java.lang.String routingKey, Message message) Send a message to a specific exchange with a specific routing key.
Message	AmqpTemplate.sendAndReceive(Message message) Basic RPC pattern.
Message	AmqpTemplate.sendAndReceive(java.lang.String routingKey, Message message) Basic RPC pattern.
Message	AmqpTemplate.sendAndReceive(java.lang.String exchange, java.lang.String routingKey, Message message) Basic RPC pattern.

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

Constructor and Description
MessageBuilder(Message message)

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

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

Modifier and Type	Field and Description
private java.util.concurrent.LinkedBlockingQueue<Message>	RabbitTemplate.PendingReply.queue

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

Modifier and Type	Method and Description
private Message	RabbitTemplate.buildMessageFromResponse(com.rabbitmq.client.GetResponse response)
protected Message	RabbitTemplate.convertMessageIfNecessary(java.lang.Object object)
protected Message	RabbitTemplate.doSendAndReceive(java.lang.String exchange, java.lang.String routingKey, Message message) Send a message and wait for a reply.
protected Message	RabbitTemplate.doSendAndReceiveWithFixed(java.lang.String exchange, java.lang.String routingKey, Message message)
protected Message	RabbitTemplate.doSendAndReceiveWithTemporary(java.lang.String exchange, java.lang.String routingKey, Message message)
Message	RabbitTemplate.receive()
Message	RabbitTemplate.receive(java.lang.String queueName)
Message	RabbitTemplate.sendAndReceive(Message message)
Message	RabbitTemplate.sendAndReceive(java.lang.String routingKey, Message message)
Message	RabbitTemplate.sendAndReceive(java.lang.String exchange, java.lang.String routingKey, Message message)

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

Modifier and Type	Method and Description
java.util.concurrent.LinkedBlockingQueue<Message>	RabbitTemplate.PendingReply.getQueue()

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

Modifier and Type	Method and Description
protected void	RabbitTemplate.doSend(com.rabbitmq.client.Channel channel, java.lang.String exchange, java.lang.String routingKey, Message message, CorrelationData correlationData) Send the given message to the specified exchange.
protected Message	RabbitTemplate.doSendAndReceive(java.lang.String exchange, java.lang.String routingKey, Message message) Send a message and wait for a reply.
protected Message	RabbitTemplate.doSendAndReceiveWithFixed(java.lang.String exchange, java.lang.String routingKey, Message message)
protected Message	RabbitTemplate.doSendAndReceiveWithTemporary(java.lang.String exchange, java.lang.String routingKey, Message message)
private Address	RabbitTemplate.getReplyToAddress(Message request) Determine a reply-to Address for the given message.
void	RabbitTemplate.onMessage(Message message)
void	ChannelAwareMessageListener.onMessage(Message message, com.rabbitmq.client.Channel channel) Callback for processing a received Rabbit message.
void	RabbitTemplate.ReturnCallback.returnedMessage(Message message, int replyCode, java.lang.String replyText, java.lang.String exchange, java.lang.String routingKey)
void	RabbitTemplate.send(Message message)
void	RabbitTemplate.send(java.lang.String routingKey, Message message)
void	RabbitTemplate.send(java.lang.String exchange, java.lang.String routingKey, Message message)
void	RabbitTemplate.send(java.lang.String exchange, java.lang.String routingKey, Message message, CorrelationData correlationData)
Message	RabbitTemplate.sendAndReceive(Message message)
Message	RabbitTemplate.sendAndReceive(java.lang.String routingKey, Message message)
Message	RabbitTemplate.sendAndReceive(java.lang.String exchange, java.lang.String routingKey, Message message)

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

Fields in org.springframework.amqp.rabbit.listener declared as Message

Modifier and Type	Field and Description
private Message	ListenerExecutionFailedException.failedMessage

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

Modifier and Type	Method and Description
Message	ListenerExecutionFailedException.getFailedMessage()
private Message	BlockingQueueConsumer.handle(BlockingQueueConsumer.Delivery delivery) If this is a non-POISON non-null delivery simply return it.
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 with parameters of type Message

Modifier and Type	Method and Description
protected void	AbstractMessageListenerContainer.doInvokeListener(ChannelAwareMessageListener listener, com.rabbitmq.client.Channel channel, Message message) Invoke the specified listener as Spring ChannelAwareMessageListener, exposing a new Rabbit Session (potentially with its own transaction) to the listener if demanded.
protected void	AbstractMessageListenerContainer.doInvokeListener(MessageListener listener, Message message) Invoke the specified listener as Spring Rabbit MessageListener.
protected void	AbstractMessageListenerContainer.executeListener(com.rabbitmq.client.Channel channel, Message message) Execute the specified listener, committing or rolling back the transaction afterwards (if necessary).
protected void	AbstractMessageListenerContainer.invokeListener(com.rabbitmq.client.Channel channel, Message message) Invoke the specified listener: either as standard MessageListener or (preferably) as SessionAwareMessageListener.
protected void	SimpleMessageListenerContainer.invokeListener(com.rabbitmq.client.Channel channel, Message message)
void	SimpleMessageListenerContainer.ContainerDelegate.invokeListener(com.rabbitmq.client.Channel channel, Message message)
protected java.lang.Exception	AbstractMessageListenerContainer.wrapToListenerExecutionFailedExceptionIfNeeded(java.lang.Exception e, Message message)

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

Constructor and Description
ListenerExecutionFailedException(java.lang.String msg, java.lang.Throwable cause, Message failedMessage) Constructor for ListenerExecutionFailedException.

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 and Description
protected Message	MessageListenerAdapter.buildMessage(com.rabbitmq.client.Channel session, java.lang.Object result) Build a Rabbit message to be sent as response based on the given result object.

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

Modifier and Type	Method and Description
protected java.lang.Object	MessageListenerAdapter.extractMessage(Message message) Extract the message body from the given Rabbit message.
protected java.lang.String	MessageListenerAdapter.getListenerMethodName(Message originalMessage, java.lang.Object extractedMessage) Determine the name of the listener method that is supposed to handle the given message.
protected java.lang.String	MessageListenerAdapter.getReceivedExchange(Message request)
protected Address	MessageListenerAdapter.getReplyToAddress(Message request) Determine a reply-to Address for the given message.
protected void	MessageListenerAdapter.handleResult(java.lang.Object result, Message request, com.rabbitmq.client.Channel channel) Handle the given result object returned from the listener method, sending a response message back.
protected java.lang.Object	MessageListenerAdapter.invokeListenerMethod(java.lang.String methodName, java.lang.Object[] arguments, Message originalMessage) Invoke the specified listener method.
void	MessageListenerAdapter.onMessage(Message message) Rabbit MessageListener entry point.
void	MessageListenerAdapter.onMessage(Message message, com.rabbitmq.client.Channel channel) Spring ChannelAwareMessageListener entry point.
protected void	MessageListenerAdapter.postProcessChannel(com.rabbitmq.client.Channel channel, Message response) Post-process the given message before sending the response.
protected void	MessageListenerAdapter.postProcessResponse(Message request, Message response) Post-process the given response message before it will be sent.
protected void	MessageListenerAdapter.sendResponse(com.rabbitmq.client.Channel channel, Address replyTo, Message message) Send the given response message to the given destination.

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 and Description
java.lang.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.
private java.lang.String	RepublishMessageRecoverer.prefixedOriginalRoutingKey(Message message)
void	RepublishMessageRecoverer.recover(Message message, java.lang.Throwable cause)
void	MessageRecoverer.recover(Message message, java.lang.Throwable cause) Callback for message that was consumed but failed all retry attempts.
void	RejectAndDontRequeueRecoverer.recover(Message message, java.lang.Throwable cause)

Uses of Message in org.springframework.amqp.remoting.service

Methods in org.springframework.amqp.remoting.service with parameters of type Message

Modifier and Type	Method and Description
void	AmqpInvokerServiceExporter.onMessage(Message message)

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

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

Modifier and Type	Method and Description
protected Message	SerializerMessageConverter.createMessage(java.lang.Object object, MessageProperties messageProperties) Creates an AMQP Message from the provided Object.
protected Message	JsonMessageConverter.createMessage(java.lang.Object objectToConvert, MessageProperties messageProperties)
protected Message	MarshallingMessageConverter.createMessage(java.lang.Object object, MessageProperties messageProperties) Marshals the given object to a Message.
protected Message	SimpleMessageConverter.createMessage(java.lang.Object object, MessageProperties messageProperties) Creates an AMQP Message from the provided Object.
protected Message	Jackson2JsonMessageConverter.createMessage(java.lang.Object objectToConvert, MessageProperties messageProperties)
protected abstract Message	AbstractMessageConverter.createMessage(java.lang.Object object, MessageProperties messageProperties) Crate a message from the payload object and message properties provided.
Message	MessageConverter.toMessage(java.lang.Object object, MessageProperties messageProperties) Convert a Java object to a Message.
Message	AbstractMessageConverter.toMessage(java.lang.Object object, MessageProperties messageProperties)

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

Modifier and Type	Method and Description
java.lang.Object	SerializerMessageConverter.fromMessage(Message message) Converts from a AMQP Message to an Object.
java.lang.Object	JsonMessageConverter.fromMessage(Message message)
java.lang.Object	MessageConverter.fromMessage(Message message) Convert from a Message to a Java object.
java.lang.Object	MarshallingMessageConverter.fromMessage(Message message) Unmarshals the given Message into an object.
java.lang.Object	SimpleMessageConverter.fromMessage(Message message) Converts from a AMQP Message to an Object.
java.lang.Object	Jackson2JsonMessageConverter.fromMessage(Message message)
abstract java.lang.Object	AbstractMessageConverter.fromMessage(Message message)