All Known Subinterfaces:: RabbitOperations

All Known Implementing Classes:: BatchingRabbitTemplate, RabbitTemplate, TestRabbitTemplate

public interface AmqpTemplate

Specifies a basic set of AMQP operations.

Provides synchronous send and receive methods. The convertAndSend(Object) and receiveAndConvert() methods allow let you send and receive POJO objects. Implementations are expected to delegate to an instance of MessageConverter to perform conversion to and from AMQP byte[] payload type.

Author:: Mark Pollack, Mark Fisher, Artem Bilan, Ernest Sadykov, Gary Russell, Artem Bilan

Method Summary

Modifier and Type

Method

Description

void

convertAndSend(@Nullable String exchange, @Nullable String routingKey, Object message)

Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.

void

convertAndSend(@Nullable String exchange, @Nullable String routingKey, Object message, MessagePostProcessor messagePostProcessor)

Convert a Java object to an Amqp Message and send it to a specific exchange with a specific routing key.

void

convertAndSend(@Nullable String routingKey, Object message)

Convert a Java object to an Amqp Message and send it to a default exchange with a specific routing key.

void

convertAndSend(@Nullable String routingKey, Object message, MessagePostProcessor messagePostProcessor)

Convert a Java object to an Amqp Message and send it to a default exchange with a specific routing key.

void

convertAndSend(Object message)

Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.

void

convertAndSend(Object message, MessagePostProcessor messagePostProcessor)

Convert a Java object to an Amqp Message and send it to a default exchange with a default routing key.

@Nullable Object

convertSendAndReceive(Object message)

Basic RPC pattern with conversion.

@Nullable Object

convertSendAndReceive(Object message, MessagePostProcessor messagePostProcessor)

Basic RPC pattern with conversion.

@Nullable Object

convertSendAndReceive(String routingKey, Object message)

Basic RPC pattern with conversion.

@Nullable Object

convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor)

Basic RPC pattern with conversion.

@Nullable Object

convertSendAndReceive(String exchange, String routingKey, Object message)

Basic RPC pattern with conversion.

@Nullable Object

convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)

Basic RPC pattern with conversion.

<T> @Nullable T

convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)

Basic RPC pattern with conversion.

<T> @Nullable T

convertSendAndReceiveAsType(Object message, ParameterizedTypeReference<T> responseType)

Basic RPC pattern with conversion.

<T> @Nullable T

convertSendAndReceiveAsType(String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)

Basic RPC pattern with conversion.

<T> @Nullable T

convertSendAndReceiveAsType(String routingKey, Object message, ParameterizedTypeReference<T> responseType)

Basic RPC pattern with conversion.

<T> @Nullable T

convertSendAndReceiveAsType(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, ParameterizedTypeReference<T> responseType)

Basic RPC pattern with conversion.

<T> @Nullable T

convertSendAndReceiveAsType(String exchange, String routingKey, Object message, ParameterizedTypeReference<T> responseType)

Basic RPC pattern with conversion.

@Nullable Message

receive()

Receive a message if there is one from a default queue.

@Nullable Message

receive(long timeoutMillis)

Receive a message from a default queue, waiting up to the specified wait time if necessary for a message to become available.

@Nullable Message

receive(String queueName)

Receive a message if there is one from a specific queue.

@Nullable Message

receive(String queueName, long timeoutMillis)

Receive a message from a specific queue, waiting up to the specified wait time if necessary for a message to become available.

@Nullable Object

receiveAndConvert()

Receive a message if there is one from a default queue and convert it to a Java object.

@Nullable Object

receiveAndConvert(long timeoutMillis)

Receive a message if there is one from a default queue and convert it to a Java object.

<T> @Nullable T

receiveAndConvert(long timeoutMillis, ParameterizedTypeReference<T> type)

Receive a message if there is one from a default queue and convert it to a Java object.

@Nullable Object

receiveAndConvert(String queueName)

Receive a message if there is one from a specific queue and convert it to a Java object.

@Nullable Object

receiveAndConvert(String queueName, long timeoutMillis)

Receive a message if there is one from a specific queue and convert it to a Java object.

<T> @Nullable T

receiveAndConvert(String queueName, long timeoutMillis, ParameterizedTypeReference<T> type)

Receive a message if there is one from a specific queue and convert it to a Java object.

<T> @Nullable T

receiveAndConvert(String queueName, ParameterizedTypeReference<T> type)

Receive a message if there is one from a specific queue and convert it to a Java object.

<T> @Nullable T

receiveAndConvert(ParameterizedTypeReference<T> type)

Receive a message if there is one from a default queue and convert it to a Java object.

<R, S> boolean

receiveAndReply(String queueName, ReceiveAndReplyCallback<R,S> callback)

Receive a message if there is one from provided queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the replyTo Address from MessageProperties or to default exchange and default routingKey.

<R, S> boolean

receiveAndReply(String queueName, ReceiveAndReplyCallback<R,S> callback, String replyExchange, String replyRoutingKey)

Receive a message if there is one from provided queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the provided exchange and routingKey.

<R, S> boolean

receiveAndReply(String queueName, ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback)

Receive a message if there is one from provided queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the replyTo Address from result of ReplyToAddressCallback.

<R, S> boolean

receiveAndReply(ReceiveAndReplyCallback<R,S> callback)

Receive a message if there is one from a default queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the replyTo Address from MessageProperties or to default exchange and default routingKey.

<R, S> boolean

receiveAndReply(ReceiveAndReplyCallback<R,S> callback, String replyExchange, String replyRoutingKey)

Receive a message if there is one from default queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the provided exchange and routingKey.

<R, S> boolean

receiveAndReply(ReceiveAndReplyCallback<R,S> callback, ReplyToAddressCallback<S> replyToAddressCallback)

Receive a message if there is one from a default queue, invoke provided ReceiveAndReplyCallback and send reply message, if the callback returns one, to the replyTo Address from result of ReplyToAddressCallback.

void

send(String exchange, String routingKey, Message message)

Send a message to a specific exchange with a specific routing key.

void

send(String routingKey, Message message)

Send a message to a default exchange with a specific routing key.

void

send(Message message)

Send a message to a default exchange with a default routing key.

@Nullable Message

sendAndReceive(String exchange, String routingKey, Message message)

Interface AmqpTemplate

Method Summary