Package org.springframework.amqp.core
Interface AsyncAmqpTemplate
-
- All Known Implementing Classes:
AsyncRabbitTemplate
public interface AsyncAmqpTemplate
Classes implementing this interface can perform asynchronous send and receive operations.- Since:
- 2.0
- Author:
- Gary Russell
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <C> ListenableFuture<C>
convertSendAndReceive(Object object)
Convert the object to a message and send it to the default exchange with the default routing key.<C> ListenableFuture<C>
convertSendAndReceive(Object object, MessagePostProcessor messagePostProcessor)
Convert the object to a message and send it to the default exchange with the default routing key after invoking theMessagePostProcessor
.<C> ListenableFuture<C>
convertSendAndReceive(String routingKey, Object object)
Convert the object to a message and send it to the default exchange with the provided routing key.<C> ListenableFuture<C>
convertSendAndReceive(String routingKey, Object object, MessagePostProcessor messagePostProcessor)
Convert the object to a message and send it to the default exchange with the provided routing key after invoking theMessagePostProcessor
.<C> ListenableFuture<C>
convertSendAndReceive(String exchange, String routingKey, Object object)
Convert the object to a message and send it to the provided exchange and routing key.<C> ListenableFuture<C>
convertSendAndReceive(String exchange, String routingKey, Object object, MessagePostProcessor messagePostProcessor)
Convert the object to a message and send it to the provided exchange and routing key after invoking theMessagePostProcessor
.<C> ListenableFuture<C>
convertSendAndReceiveAsType(Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the default exchange with the default routing key after invoking theMessagePostProcessor
.<C> ListenableFuture<C>
convertSendAndReceiveAsType(Object object, ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the default exchange with the default routing key.<C> ListenableFuture<C>
convertSendAndReceiveAsType(String routingKey, Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the default exchange with the provided routing key after invoking theMessagePostProcessor
.<C> ListenableFuture<C>
convertSendAndReceiveAsType(String routingKey, Object object, ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the default exchange with the provided routing key.<C> ListenableFuture<C>
convertSendAndReceiveAsType(String exchange, String routingKey, Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the provided exchange and routing key after invoking theMessagePostProcessor
.<C> ListenableFuture<C>
convertSendAndReceiveAsType(String exchange, String routingKey, Object object, ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the provided exchange and routing key.ListenableFuture<Message>
sendAndReceive(String exchange, String routingKey, Message message)
Send a message to the supplied exchange and routing key.ListenableFuture<Message>
sendAndReceive(String routingKey, Message message)
Send a message to the default exchange with the supplied routing key.ListenableFuture<Message>
sendAndReceive(Message message)
Send a message to the default exchange with the default routing key.
-
-
-
Method Detail
-
sendAndReceive
ListenableFuture<Message> sendAndReceive(Message message)
Send a message to the default exchange with the default routing key. If the message contains a correlationId property, it must be unique.- Parameters:
message
- the message.- Returns:
- the
ListenableFuture
.
-
sendAndReceive
ListenableFuture<Message> sendAndReceive(String routingKey, Message message)
Send a message to the default exchange with the supplied routing key. If the message contains a correlationId property, it must be unique.- Parameters:
routingKey
- the routing key.message
- the message.- Returns:
- the
ListenableFuture
.
-
sendAndReceive
ListenableFuture<Message> sendAndReceive(String exchange, String routingKey, Message message)
Send a message to the supplied exchange and routing key. If the message contains a correlationId property, it must be unique.- Parameters:
exchange
- the exchange.routingKey
- the routing key.message
- the message.- Returns:
- the
ListenableFuture
.
-
convertSendAndReceive
<C> ListenableFuture<C> convertSendAndReceive(Object object)
Convert the object to a message and send it to the default exchange with the default routing key.- Type Parameters:
C
- the expected result type.- Parameters:
object
- the object to convert.- Returns:
- the
ListenableFuture
.
-
convertSendAndReceive
<C> ListenableFuture<C> convertSendAndReceive(String routingKey, Object object)
Convert the object to a message and send it to the default exchange with the provided routing key.- Type Parameters:
C
- the expected result type.- Parameters:
routingKey
- the routing key.object
- the object to convert.- Returns:
- the
ListenableFuture
.
-
convertSendAndReceive
<C> ListenableFuture<C> convertSendAndReceive(String exchange, String routingKey, Object object)
Convert the object to a message and send it to the provided exchange and routing key.- Type Parameters:
C
- the expected result type.- Parameters:
exchange
- the exchange.routingKey
- the routing key.object
- the object to convert.- Returns:
- the
ListenableFuture
.
-
convertSendAndReceive
<C> ListenableFuture<C> convertSendAndReceive(Object object, MessagePostProcessor messagePostProcessor)
Convert the object to a message and send it to the default exchange with the default routing key after invoking theMessagePostProcessor
. If the post processor adds a correlationId property, it must be unique.- Type Parameters:
C
- the expected result type.- Parameters:
object
- the object to convert.messagePostProcessor
- the post processor.- Returns:
- the
ListenableFuture
.
-
convertSendAndReceive
<C> ListenableFuture<C> convertSendAndReceive(String routingKey, Object object, MessagePostProcessor messagePostProcessor)
Convert the object to a message and send it to the default exchange with the provided routing key after invoking theMessagePostProcessor
. If the post processor adds a correlationId property, it must be unique.- Type Parameters:
C
- the expected result type.- Parameters:
routingKey
- the routing key.object
- the object to convert.messagePostProcessor
- the post processor.- Returns:
- the
ListenableFuture
.
-
convertSendAndReceive
<C> ListenableFuture<C> convertSendAndReceive(String exchange, String routingKey, Object object, MessagePostProcessor messagePostProcessor)
Convert the object to a message and send it to the provided exchange and routing key after invoking theMessagePostProcessor
. If the post processor adds a correlationId property, it must be unique.- Type Parameters:
C
- the expected result type.- Parameters:
exchange
- the exchangeroutingKey
- the routing key.object
- the object to convert.messagePostProcessor
- the post processor.- Returns:
- the
ListenableFuture
.
-
convertSendAndReceiveAsType
<C> ListenableFuture<C> convertSendAndReceiveAsType(Object object, ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the default exchange with the default routing key.- Type Parameters:
C
- the expected result type.- Parameters:
object
- the object to convert.responseType
- the response type.- Returns:
- the
ListenableFuture
.
-
convertSendAndReceiveAsType
<C> ListenableFuture<C> convertSendAndReceiveAsType(String routingKey, Object object, ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the default exchange with the provided routing key.- Type Parameters:
C
- the expected result type.- Parameters:
routingKey
- the routing key.object
- the object to convert.responseType
- the response type.- Returns:
- the
ListenableFuture
.
-
convertSendAndReceiveAsType
<C> ListenableFuture<C> convertSendAndReceiveAsType(String exchange, String routingKey, Object object, ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the provided exchange and routing key.- Type Parameters:
C
- the expected result type.- Parameters:
exchange
- the exchange.routingKey
- the routing key.object
- the object to convert.responseType
- the response type.- Returns:
- the
ListenableFuture
.
-
convertSendAndReceiveAsType
<C> ListenableFuture<C> convertSendAndReceiveAsType(Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the default exchange with the default routing key after invoking theMessagePostProcessor
. If the post processor adds a correlationId property, it must be unique.- Type Parameters:
C
- the expected result type.- Parameters:
object
- the object to convert.messagePostProcessor
- the post processor.responseType
- the response type.- Returns:
- the
ListenableFuture
.
-
convertSendAndReceiveAsType
<C> ListenableFuture<C> convertSendAndReceiveAsType(String routingKey, Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the default exchange with the provided routing key after invoking theMessagePostProcessor
. If the post processor adds a correlationId property, it must be unique.- Type Parameters:
C
- the expected result type.- Parameters:
routingKey
- the routing key.object
- the object to convert.messagePostProcessor
- the post processor.responseType
- the response type.- Returns:
- the
ListenableFuture
.
-
convertSendAndReceiveAsType
<C> ListenableFuture<C> convertSendAndReceiveAsType(String exchange, String routingKey, Object object, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the provided exchange and routing key after invoking theMessagePostProcessor
. If the post processor adds a correlationId property, it must be unique.- Type Parameters:
C
- the expected result type.- Parameters:
exchange
- the exchangeroutingKey
- the routing key.object
- the object to convert.messagePostProcessor
- the post processor.responseType
- the response type.- Returns:
- the
ListenableFuture
.
-
-