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

Modifier and Type	Method and 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 the MessagePostProcessor.
<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 the MessagePostProcessor.
<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 the MessagePostProcessor.
<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 the MessagePostProcessor.
<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 the MessagePostProcessor.
<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 the MessagePostProcessor.
<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(Message message) Send a message to the default exchange with the default routing key.
ListenableFuture<Message>	sendAndReceive(String routingKey, Message message) Send a message to the default exchange with the supplied routing key.
ListenableFuture<Message>	sendAndReceive(String exchange, String routingKey, Message message) Send a message to the supplied exchange and 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 the MessagePostProcessor. 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 the MessagePostProcessor. 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 the MessagePostProcessor. If the post processor adds a correlationId property, it must be unique.

Type Parameters:

C - the expected result type.

Parameters:

exchange - the exchange

routingKey - 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 the MessagePostProcessor. 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 the MessagePostProcessor. 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 the MessagePostProcessor. If the post processor adds a correlationId property, it must be unique.

Type Parameters:

C - the expected result type.

Parameters:

exchange - the exchange

routingKey - the routing key.

object - the object to convert.

messagePostProcessor - the post processor.

responseType - the response type.

Returns:

the ListenableFuture.