public interface AsyncAmqpTemplate
Modifier and Type | Method and Description |
---|---|
<C> org.springframework.util.concurrent.ListenableFuture<C> |
convertSendAndReceive(java.lang.Object object)
Convert the object to a message and send it to the default exchange with the
default routing key.
|
<C> org.springframework.util.concurrent.ListenableFuture<C> |
convertSendAndReceive(java.lang.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> org.springframework.util.concurrent.ListenableFuture<C> |
convertSendAndReceive(java.lang.String routingKey,
java.lang.Object object)
Convert the object to a message and send it to the default exchange with the
provided routing key.
|
<C> org.springframework.util.concurrent.ListenableFuture<C> |
convertSendAndReceive(java.lang.String routingKey,
java.lang.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> org.springframework.util.concurrent.ListenableFuture<C> |
convertSendAndReceive(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object object)
Convert the object to a message and send it to the provided exchange and
routing key.
|
<C> org.springframework.util.concurrent.ListenableFuture<C> |
convertSendAndReceive(java.lang.String exchange,
java.lang.String routingKey,
java.lang.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> org.springframework.util.concurrent.ListenableFuture<C> |
convertSendAndReceiveAsType(java.lang.Object object,
MessagePostProcessor messagePostProcessor,
org.springframework.core.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> org.springframework.util.concurrent.ListenableFuture<C> |
convertSendAndReceiveAsType(java.lang.Object object,
org.springframework.core.ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the default exchange with the
default routing key.
|
<C> org.springframework.util.concurrent.ListenableFuture<C> |
convertSendAndReceiveAsType(java.lang.String routingKey,
java.lang.Object object,
MessagePostProcessor messagePostProcessor,
org.springframework.core.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> org.springframework.util.concurrent.ListenableFuture<C> |
convertSendAndReceiveAsType(java.lang.String routingKey,
java.lang.Object object,
org.springframework.core.ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the default exchange with the
provided routing key.
|
<C> org.springframework.util.concurrent.ListenableFuture<C> |
convertSendAndReceiveAsType(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object object,
MessagePostProcessor messagePostProcessor,
org.springframework.core.ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the provided exchange and
routing key after invoking the
MessagePostProcessor . |
<C> org.springframework.util.concurrent.ListenableFuture<C> |
convertSendAndReceiveAsType(java.lang.String exchange,
java.lang.String routingKey,
java.lang.Object object,
org.springframework.core.ParameterizedTypeReference<C> responseType)
Convert the object to a message and send it to the provided exchange and
routing key.
|
org.springframework.util.concurrent.ListenableFuture<Message> |
sendAndReceive(Message message)
Send a message to the default exchange with the default routing key.
|
org.springframework.util.concurrent.ListenableFuture<Message> |
sendAndReceive(java.lang.String routingKey,
Message message)
Send a message to the default exchange with the supplied routing key.
|
org.springframework.util.concurrent.ListenableFuture<Message> |
sendAndReceive(java.lang.String exchange,
java.lang.String routingKey,
Message message)
Send a message to the supplied exchange and routing key.
|
org.springframework.util.concurrent.ListenableFuture<Message> sendAndReceive(Message message)
message
- the message.ListenableFuture
.org.springframework.util.concurrent.ListenableFuture<Message> sendAndReceive(java.lang.String routingKey, Message message)
routingKey
- the routing key.message
- the message.ListenableFuture
.org.springframework.util.concurrent.ListenableFuture<Message> sendAndReceive(java.lang.String exchange, java.lang.String routingKey, Message message)
exchange
- the exchange.routingKey
- the routing key.message
- the message.ListenableFuture
.<C> org.springframework.util.concurrent.ListenableFuture<C> convertSendAndReceive(java.lang.Object object)
C
- the expected result type.object
- the object to convert.ListenableFuture
.<C> org.springframework.util.concurrent.ListenableFuture<C> convertSendAndReceive(java.lang.String routingKey, java.lang.Object object)
C
- the expected result type.routingKey
- the routing key.object
- the object to convert.ListenableFuture
.<C> org.springframework.util.concurrent.ListenableFuture<C> convertSendAndReceive(java.lang.String exchange, java.lang.String routingKey, java.lang.Object object)
C
- the expected result type.exchange
- the exchange.routingKey
- the routing key.object
- the object to convert.ListenableFuture
.<C> org.springframework.util.concurrent.ListenableFuture<C> convertSendAndReceive(java.lang.Object object, MessagePostProcessor messagePostProcessor)
MessagePostProcessor
.
If the post processor adds a correlationId property, it must be unique.C
- the expected result type.object
- the object to convert.messagePostProcessor
- the post processor.ListenableFuture
.<C> org.springframework.util.concurrent.ListenableFuture<C> convertSendAndReceive(java.lang.String routingKey, java.lang.Object object, MessagePostProcessor messagePostProcessor)
MessagePostProcessor
.
If the post processor adds a correlationId property, it must be unique.C
- the expected result type.routingKey
- the routing key.object
- the object to convert.messagePostProcessor
- the post processor.ListenableFuture
.<C> org.springframework.util.concurrent.ListenableFuture<C> convertSendAndReceive(java.lang.String exchange, java.lang.String routingKey, java.lang.Object object, MessagePostProcessor messagePostProcessor)
MessagePostProcessor
.
If the post processor adds a correlationId property, it must be unique.C
- the expected result type.exchange
- the exchangeroutingKey
- the routing key.object
- the object to convert.messagePostProcessor
- the post processor.ListenableFuture
.<C> org.springframework.util.concurrent.ListenableFuture<C> convertSendAndReceiveAsType(java.lang.Object object, org.springframework.core.ParameterizedTypeReference<C> responseType)
C
- the expected result type.object
- the object to convert.responseType
- the response type.ListenableFuture
.<C> org.springframework.util.concurrent.ListenableFuture<C> convertSendAndReceiveAsType(java.lang.String routingKey, java.lang.Object object, org.springframework.core.ParameterizedTypeReference<C> responseType)
C
- the expected result type.routingKey
- the routing key.object
- the object to convert.responseType
- the response type.ListenableFuture
.<C> org.springframework.util.concurrent.ListenableFuture<C> convertSendAndReceiveAsType(java.lang.String exchange, java.lang.String routingKey, java.lang.Object object, org.springframework.core.ParameterizedTypeReference<C> responseType)
C
- the expected result type.exchange
- the exchange.routingKey
- the routing key.object
- the object to convert.responseType
- the response type.ListenableFuture
.<C> org.springframework.util.concurrent.ListenableFuture<C> convertSendAndReceiveAsType(java.lang.Object object, MessagePostProcessor messagePostProcessor, org.springframework.core.ParameterizedTypeReference<C> responseType)
MessagePostProcessor
.
If the post processor adds a correlationId property, it must be unique.C
- the expected result type.object
- the object to convert.messagePostProcessor
- the post processor.responseType
- the response type.ListenableFuture
.<C> org.springframework.util.concurrent.ListenableFuture<C> convertSendAndReceiveAsType(java.lang.String routingKey, java.lang.Object object, MessagePostProcessor messagePostProcessor, org.springframework.core.ParameterizedTypeReference<C> responseType)
MessagePostProcessor
.
If the post processor adds a correlationId property, it must be unique.C
- the expected result type.routingKey
- the routing key.object
- the object to convert.messagePostProcessor
- the post processor.responseType
- the response type.ListenableFuture
.<C> org.springframework.util.concurrent.ListenableFuture<C> convertSendAndReceiveAsType(java.lang.String exchange, java.lang.String routingKey, java.lang.Object object, MessagePostProcessor messagePostProcessor, org.springframework.core.ParameterizedTypeReference<C> responseType)
MessagePostProcessor
.
If the post processor adds a correlationId property, it must be unique.C
- the expected result type.exchange
- the exchangeroutingKey
- the routing key.object
- the object to convert.messagePostProcessor
- the post processor.responseType
- the response type.ListenableFuture
.