Uses of Class
org.springframework.amqp.rabbit.connection.CorrelationData
Packages that use 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
Methods in org.springframework.amqp.rabbit with parameters of type CorrelationDataModifier and TypeMethodDescriptionvoidAsyncRabbitTemplate.confirm(CorrelationData correlationData, boolean ack, String cause) -
Uses of CorrelationData in org.springframework.amqp.rabbit.connection
Methods in org.springframework.amqp.rabbit.connection that return CorrelationDataModifier and TypeMethodDescriptionPendingConfirm.getCorrelationData()The correlation data supplied by the client when sending the message corresponding to this confirmation.Constructors in org.springframework.amqp.rabbit.connection with parameters of type CorrelationData -
Uses of CorrelationData in org.springframework.amqp.rabbit.core
Methods in org.springframework.amqp.rabbit.core that return CorrelationDataModifier and TypeMethodDescriptionCorrelationDataPostProcessor.postProcess(Message message, CorrelationData correlationData) Update or replace the correlation data provided in the send method.Methods in org.springframework.amqp.rabbit.core that return types with arguments of type CorrelationDataModifier and TypeMethodDescriptionRabbitTemplate.getUnconfirmed(long age) Gets unconfirmed correlation data older than age and removes them.Methods in org.springframework.amqp.rabbit.core with parameters of type CorrelationDataModifier and TypeMethodDescriptionvoidRabbitTemplate.ConfirmCallback.confirm(CorrelationData correlationData, boolean ack, String cause) Confirmation callback.voidRabbitOperations.convertAndSend(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Convert a Java object to an AmqpMessageand send it to a default exchange with a default routing key.voidRabbitOperations.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Convert a Java object to an AmqpMessageand send it to a default exchange with a specific routing key.voidRabbitOperations.convertAndSend(String routingKey, Object message, CorrelationData correlationData) Convert a Java object to an AmqpMessageand send it to a default exchange with a specific routing key.voidRabbitOperations.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) Convert a Java object to an AmqpMessageand send it to a specific exchange with a specific routing key.voidRabbitOperations.convertAndSend(String exchange, String routingKey, Object message, CorrelationData correlationData) Convert a Java object to an AmqpMessageand send it to a specific exchange with a specific routing key.voidRabbitTemplate.convertAndSend(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) voidRabbitTemplate.convertAndSend(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) voidRabbitTemplate.convertAndSend(String routingKey, Object object, CorrelationData correlationData) voidRabbitTemplate.convertAndSend(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData) voidRabbitTemplate.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> TRabbitOperations.convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> TRabbitOperations.convertSendAndReceiveAsType(Object message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> TRabbitOperations.convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> TRabbitOperations.convertSendAndReceiveAsType(String routingKey, Object message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> TRabbitOperations.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.default <T> TRabbitOperations.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) Basic RPC pattern with conversion.<T> TRabbitTemplate.convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> TRabbitTemplate.convertSendAndReceiveAsType(Object message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> TRabbitTemplate.convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> TRabbitTemplate.convertSendAndReceiveAsType(String routingKey, Object message, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) <T> TRabbitTemplate.convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, CorrelationData correlationData, ParameterizedTypeReference<T> responseType) 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.voidRabbitOperations.correlationConvertAndSend(Object message, CorrelationData correlationData) Convert a Java object to an AmqpMessageand send it to a default exchange with a default routing key.voidRabbitTemplate.correlationConvertAndSend(Object object, CorrelationData correlationData) 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) CorrelationDataPostProcessor.postProcess(Message message, CorrelationData correlationData) Update or replace the correlation data provided in the send method.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.voidRabbitTemplate.send(String exchange, String routingKey, Message message, CorrelationData correlationData) voidRabbitTemplate.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
Methods in org.springframework.amqp.rabbit.test with parameters of type CorrelationDataModifier and TypeMethodDescriptionprotected MessageTestRabbitTemplate.doSendAndReceiveWithFixed(String exchange, String routingKey, Message message, CorrelationData correlationData)