Uses of Class
org.springframework.amqp.rabbit.connection.CorrelationData
Package
Description
Provides top-level classes for Spring Rabbit.
Provides classes related to connections.
Provides core classes for Spring Rabbit.
Classes for testing Spring AMQP applications.
-
Uses of CorrelationData in org.springframework.amqp.rabbit
Modifier and TypeMethodDescriptionvoid
AsyncRabbitTemplate.confirm
(CorrelationData correlationData, boolean ack, String cause) -
Uses of CorrelationData in org.springframework.amqp.rabbit.connection
Modifier and TypeMethodDescriptionPendingConfirm.getCorrelationData()
The correlation data supplied by the client when sending the message corresponding to this confirmation. -
Uses of CorrelationData in org.springframework.amqp.rabbit.core
Modifier and TypeMethodDescriptionCorrelationDataPostProcessor.postProcess
(Message message, CorrelationData correlationData) Update or replace the correlation data provided in the send method.Modifier and TypeMethodDescriptionRabbitTemplate.getUnconfirmed
(long age) Gets unconfirmed correlation data older than age and removes them.Modifier and TypeMethodDescriptionvoid
RabbitTemplate.ConfirmCallback.confirm
(CorrelationData correlationData, boolean ack, String cause) Confirmation callback.void
RabbitOperations.convertAndSend
(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Convert a Java object to an AmqpMessage
and send it to a default exchange with a default routing key.void
RabbitOperations.convertAndSend
(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Convert a Java object to an AmqpMessage
and send it to a default exchange with a specific routing key.void
RabbitOperations.convertAndSend
(String routingKey, Object message, CorrelationData correlationData) Convert a Java object to an AmqpMessage
and send it to a default exchange with a specific routing key.void
RabbitOperations.convertAndSend
(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Convert a Java object to an AmqpMessage
and send it to a specific exchange with a specific routing key.void
RabbitOperations.convertAndSend
(String exchange, String routingKey, Object message, CorrelationData correlationData) Convert a Java object to an AmqpMessage
and send it to a specific exchange with a specific routing key.void
RabbitTemplate.convertAndSend
(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) void
RabbitTemplate.convertAndSend
(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) void
RabbitTemplate.convertAndSend
(String routingKey, Object object, CorrelationData correlationData) void
RabbitTemplate.convertAndSend
(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) void
RabbitTemplate.convertAndSend
(String exchange, String routingKey, Object object, CorrelationData correlationData) RabbitOperations.convertSendAndReceive
(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Basic RPC pattern with conversion.RabbitOperations.convertSendAndReceive
(Object message, CorrelationData correlationData) Basic RPC pattern with conversion.RabbitOperations.convertSendAndReceive
(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Basic RPC pattern with conversion.RabbitOperations.convertSendAndReceive
(String routingKey, Object message, CorrelationData correlationData) Basic RPC pattern with conversion.RabbitOperations.convertSendAndReceive
(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Basic RPC pattern with conversion.RabbitOperations.convertSendAndReceive
(String exchange, String routingKey, Object message, CorrelationData correlationData) Basic RPC pattern with conversion.RabbitTemplate.convertSendAndReceive
(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive
(Object message, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive
(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive
(String routingKey, Object message, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive
(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) RabbitTemplate.convertSendAndReceive
(String exchange, String routingKey, Object message, CorrelationData correlationData) <T> T
RabbitOperations.convertSendAndReceiveAsType
(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> T
RabbitOperations.convertSendAndReceiveAsType
(Object message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> T
RabbitOperations.convertSendAndReceiveAsType
(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> T
RabbitOperations.convertSendAndReceiveAsType
(String routingKey, Object message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> T
RabbitOperations.convertSendAndReceiveAsType
(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.default <T> T
RabbitOperations.convertSendAndReceiveAsType
(String exchange, String routingKey, Object message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> T
RabbitTemplate.convertSendAndReceiveAsType
(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(Object message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(String routingKey, Object message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> T
RabbitTemplate.convertSendAndReceiveAsType
(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 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.void
RabbitOperations.correlationConvertAndSend
(Object message, CorrelationData correlationData) Convert a Java object to an AmqpMessage
and send it to a default exchange with a default routing key.void
RabbitTemplate.correlationConvertAndSend
(Object object, CorrelationData correlationData) 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) 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, CorrelationData correlationData) void
RabbitTemplate.send
(String routingKey, Message message, CorrelationData correlationData) RabbitTemplate.sendAndReceive
(String exchange, String routingKey, Message message, CorrelationData correlationData) RabbitTemplate.sendAndReceive
(String routingKey, Message message, CorrelationData correlationData) RabbitTemplate.sendAndReceive
(Message message, CorrelationData correlationData) -
Uses of CorrelationData in org.springframework.amqp.rabbit.test
Modifier and TypeMethodDescriptionprotected Message
TestRabbitTemplate.doSendAndReceiveWithFixed
(String exchange, String routingKey, Message message, CorrelationData correlationData)