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 supporting retries.
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 MessageMessagePostProcessor.postProcessMessage(Message message, Correlation correlation) Change (or replace) the message and/or change its correlation data.default MessageMessagePostProcessor.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 MessageBuilderMessageBuilder.fromClonedMessage(Message message) The final message will have a copy of the message body, the MessageProperties will be cloned (top level only).static MessageBuilderMessageBuilder.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 voidvoidDelivers a single message.MessagePostProcessor.postProcessMessage(Message message) Change (or replace) the message.default MessageMessagePostProcessor.postProcessMessage(Message message, Correlation correlation) Change (or replace) the message and/or change its correlation data.default MessageMessagePostProcessor.postProcessMessage(Message message, Correlation correlation, String exchange, String routingKey) Change (or replace) the message and/or change its correlation data.voidSend a message to a specific exchange with a specific routing key.voidSend a message to a default exchange with a specific routing key.voidSend 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 TypeMethodDescriptionvoidBatchMessageListener.onMessageBatch(List<Message> messages) default voidMessageListener.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 TypeMethodDescriptionvoidAsyncRabbitTemplate.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 voidDecode a message into fragments.voidDebatch a message that has a header withMessageProperties.SPRING_BATCH_FORMATset toMessageProperties.BATCH_FORMAT_LENGTH_HEADER4.Method parameters in org.springframework.amqp.rabbit.batch with type arguments of type MessageModifier and TypeMethodDescriptiondefault voidDecode a message into fragments.voidDebatch a message that has a header withMessageProperties.SPRING_BATCH_FORMATset 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 TypeMethodDescriptionvoidCorrelationData.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 MessageRabbitTemplate.convertMessageIfNecessary(Object object) protected MessageRabbitTemplate.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 MessageRabbitTemplate.doReceiveNoWait(String queueName) Non-blocking receive.protected MessageRabbitTemplate.doSendAndReceive(String exchange, String routingKey, Message message, CorrelationData correlationData) Send a message and wait for a reply.protected MessageRabbitTemplate.doSendAndReceiveWithFixed(String exchange, String routingKey, Message message, CorrelationData correlationData) protected MessageRabbitTemplate.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) voidRabbitTemplate.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 MessageRabbitTemplate.doSendAndReceive(String exchange, String routingKey, Message message, CorrelationData correlationData) Send a message and wait for a reply.protected MessageRabbitTemplate.doSendAndReceiveWithFixed(String exchange, String routingKey, Message message, CorrelationData correlationData) protected MessageRabbitTemplate.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.voidvoidDeprecated.voidCorrelationDataPostProcessor.postProcess(Message message, CorrelationData correlationData) Update or replace the correlation data provided in the send method.voidRabbitTemplate.ReturnCallback.returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) Deprecated.Returned message callback.default voidRabbitTemplate.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.voidBatchingRabbitTemplate.send(String exchange, String routingKey, Message message, CorrelationData correlationData) voidRabbitOperations.send(String exchange, String routingKey, Message message, CorrelationData correlationData) Send a message to a specific exchange with a specific routing key.default voidRabbitOperations.send(String routingKey, Message message, CorrelationData correlationData) Send a message to the default exchange with a specific routing key.voidvoidRabbitTemplate.send(String exchange, String routingKey, Message message, CorrelationData correlationData) voidvoidRabbitTemplate.send(String routingKey, Message message, CorrelationData correlationData) voidRabbitTemplate.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 voidRabbitTemplate.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 MessageAbstractAdaptableMessageListener.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 MessageMessagingMessageListenerAdapter.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 MessageAbstractAdaptableMessageListener.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 voidAbstractAdaptableMessageListener.doHandleResult(InvocationResult resultArg, Message request, com.rabbitmq.client.Channel channel, Object source) protected voidAbstractAdaptableMessageListener.doPublish(com.rabbitmq.client.Channel channel, Address replyTo, Message message) protected ObjectAbstractAdaptableMessageListener.extractMessage(Message message) Extract the message body from the given Rabbit message.protected ObjectMessagingMessageListenerAdapter.MessagingMessageConverterAdapter.extractPayload(Message message) protected StringMessageListenerAdapter.getListenerMethodName(Message originalMessage, Object extractedMessage) Determine the name of the listener method that will handle the given message.protected StringAbstractAdaptableMessageListener.getReceivedExchange(Message request) protected AddressAbstractAdaptableMessageListener.getReplyToAddress(Message request, Object source, InvocationResult result) Determine a reply-to Address for the given message.protected voidAbstractAdaptableMessageListener.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 voidAbstractAdaptableMessageListener.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 voidMessagingMessageListenerAdapter.invokeHandlerAndProcessResult(Message amqpMessage, com.rabbitmq.client.Channel channel, Message<?> message) protected ObjectMessageListenerAdapter.invokeListenerMethod(String methodName, Object[] arguments, Message originalMessage) Invoke the specified listener method.voidSpringChannelAwareMessageListenerentry point.voidprotected voidAbstractAdaptableMessageListener.postProcessChannel(com.rabbitmq.client.Channel channel, Message response) Post-process the given message before sending the response.protected voidAbstractAdaptableMessageListener.postProcessResponse(Message request, Message response) Post-process the given response message before it will be sent.protected voidAbstractAdaptableMessageListener.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 TypeMethodDescriptionvoidBatchMessagingMessageListenerAdapter.onMessageBatch(List<Message> messages, com.rabbitmq.client.Channel channel) Constructors in org.springframework.amqp.rabbit.listener.adapter with parameters of type MessageModifierConstructorDescriptionprotectedReplyExpressionRoot(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 voiddefault voidvoidCallback for processing a received Rabbit message.Method parameters in org.springframework.amqp.rabbit.listener.api with type arguments of type MessageModifier and TypeMethodDescriptionvoidChannelAwareBatchMessageListener.onMessageBatch(List<Message> messages, com.rabbitmq.client.Channel channel) default voidChannelAwareMessageListener.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 MessageAmqpAppender.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 MessageAmqpAppender.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 MessageAmqpAppender.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 MessageAmqpAppender.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 voidSend the message.protected voidGenerate a unique key for the message that is repeatable on redelivery.booleanQuery a message to see if it has been seen before.voiddefault voidvoidCallback for message that was consumed but failed all retry attempts.voidvoidMethod 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 MessageTestRabbitTemplate.doSendAndReceiveWithFixed(String exchange, String routingKey, Message message, CorrelationData correlationData) Methods in org.springframework.amqp.rabbit.test with parameters of type MessageModifier and TypeMethodDescriptionprotected MessageTestRabbitTemplate.doSendAndReceiveWithFixed(String exchange, String routingKey, Message message, CorrelationData correlationData) protected voidTestRabbitTemplate.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 MessageSendRetryContextAccessor.getMessage(org.springframework.retry.RetryContext context) Retrieve theMessagefrom the context. -
Uses of Message in org.springframework.amqp.support.converter
Methods in org.springframework.amqp.support.converter that return MessageModifier and TypeMethodDescriptionprotected MessageAbstractJackson2MessageConverter.createMessage(Object objectToConvert, MessageProperties messageProperties) protected MessageAbstractJackson2MessageConverter.createMessage(Object objectToConvert, MessageProperties messageProperties, Type genericType) protected abstract MessageAbstractMessageConverter.createMessage(Object object, MessageProperties messageProperties) Crate a message from the payload object and message properties provided.protected MessageAbstractMessageConverter.createMessage(Object object, MessageProperties messageProperties, Type genericType) Crate a message from the payload object and message properties provided.protected MessageMarshallingMessageConverter.createMessage(Object object, MessageProperties messageProperties) Marshals the given object to aMessage.protected MessageSerializerMessageConverter.createMessage(Object object, MessageProperties messageProperties) Creates an AMQP Message from the provided Object.protected MessageSimpleMessageConverter.createMessage(Object object, MessageProperties messageProperties) Creates an AMQP Message from the provided Object.final MessageAbstractMessageConverter.toMessage(Object object, MessageProperties messageProperties) final MessageAbstractMessageConverter.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 MessageMessageConverter.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 ObjectMessagingMessageConverter.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 givenMessageinto 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.retry
Methods in org.springframework.rabbit.stream.retry with parameters of type 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 MessageStreamMessageConverter.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.MessageDefaultStreamMessageConverter.fromMessage(Message message) com.rabbitmq.stream.MessageStreamMessageConverter.fromMessage(Message message)
CorrelationData.getReturned().