|
Spring AMQP | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
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.
| Method Summary | |
|---|---|
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. |
void |
convertAndSend(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(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(String exchange,
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(String exchange,
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. |
Object |
convertSendAndReceive(Object message)
Basic RPC pattern with conversion. |
Object |
convertSendAndReceive(Object message,
MessagePostProcessor messagePostProcessor)
Basic RPC pattern with conversion. |
Object |
convertSendAndReceive(String routingKey,
Object message)
Basic RPC pattern with conversion. |
Object |
convertSendAndReceive(String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
Basic RPC pattern with conversion. |
Object |
convertSendAndReceive(String exchange,
String routingKey,
Object message)
Basic RPC pattern with conversion. |
Object |
convertSendAndReceive(String exchange,
String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
Basic RPC pattern with conversion. |
Message |
receive()
Receive a message if there is one from a default queue. |
Message |
receive(String queueName)
Receive a message if there is one from a specific queue. |
Object |
receiveAndConvert()
Receive a message if there is one from a default queue and convert it to a Java object. |
Object |
receiveAndConvert(String queueName)
Receive a message if there is one from a specific queue and convert it to a Java object. |
void |
send(Message message)
Send a message to a default exchange with a default routing key. |
void |
send(String routingKey,
Message message)
Send a message to a default exchange with a specific routing key. |
void |
send(String exchange,
String routingKey,
Message message)
Send a message to a specific exchange with a specific routing key. |
Message |
sendAndReceive(Message message)
Basic RPC pattern. |
Message |
sendAndReceive(String routingKey,
Message message)
Basic RPC pattern. |
Message |
sendAndReceive(String exchange,
String routingKey,
Message message)
Basic RPC pattern. |
| Method Detail |
|---|
void send(Message message)
throws AmqpException
message - a message to send
AmqpException - if there is a problem
void send(String routingKey,
Message message)
throws AmqpException
routingKey - the routing keymessage - a message to send
AmqpException - if there is a problem
void send(String exchange,
String routingKey,
Message message)
throws AmqpException
exchange - the name of the exchangeroutingKey - the routing keymessage - a message to send
AmqpException - if there is a problem
void convertAndSend(Object message)
throws AmqpException
Message and send it to a default exchange with a default routing key.
message - a message to send
AmqpException - if there is a problem
void convertAndSend(String routingKey,
Object message)
throws AmqpException
Message and send it to a default exchange with a specific routing key.
routingKey - the routing keymessage - a message to send
AmqpException - if there is a problem
void convertAndSend(String exchange,
String routingKey,
Object message)
throws AmqpException
Message and send it to a specific exchange with a specific routing key.
exchange - the name of the exchangeroutingKey - the routing keymessage - a message to send
AmqpException - if there is a problem
void convertAndSend(Object message,
MessagePostProcessor messagePostProcessor)
throws AmqpException
Message and send it to a default exchange with a default routing key.
message - a message to sendmessagePostProcessor - a processor to apply to the message before it is sent
AmqpException - if there is a problem
void convertAndSend(String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
throws AmqpException
Message and send it to a default exchange with a specific routing key.
routingKey - the routing keymessage - a message to sendmessagePostProcessor - a processor to apply to the message before it is sent
AmqpException - if there is a problem
void convertAndSend(String exchange,
String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
throws AmqpException
Message and send it to a specific exchange with a specific routing key.
exchange - the name of the exchangeroutingKey - the routing keymessage - a message to sendmessagePostProcessor - a processor to apply to the message before it is sent
AmqpException - if there is a problem
Message receive()
throws AmqpException
AmqpException - if there is a problem
Message receive(String queueName)
throws AmqpException
queueName - the name of the queue to poll
AmqpException - if there is a problem
Object receiveAndConvert()
throws AmqpException
AmqpException - if there is a problem
Object receiveAndConvert(String queueName)
throws AmqpException
queueName - the name of the queue to poll
AmqpException - if there is a problem
Message sendAndReceive(Message message)
throws AmqpException
message - a message to send
AmqpException - if there is a problem
Message sendAndReceive(String routingKey,
Message message)
throws AmqpException
routingKey - the routing keymessage - a message to send
AmqpException - if there is a problem
Message sendAndReceive(String exchange,
String routingKey,
Message message)
throws AmqpException
exchange - the name of the exchangeroutingKey - the routing keymessage - a message to send
AmqpException - if there is a problem
Object convertSendAndReceive(Object message)
throws AmqpException
message - a message to send
AmqpException - if there is a problem
Object convertSendAndReceive(String routingKey,
Object message)
throws AmqpException
routingKey - the routing keymessage - a message to send
AmqpException - if there is a problem
Object convertSendAndReceive(String exchange,
String routingKey,
Object message)
throws AmqpException
exchange - the name of the exchangeroutingKey - the routing keymessage - a message to send
AmqpException - if there is a problem
Object convertSendAndReceive(Object message,
MessagePostProcessor messagePostProcessor)
throws AmqpException
message - a message to sendmessagePostProcessor - a processor to apply to the message before it is sent
AmqpException - if there is a problem
Object convertSendAndReceive(String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
throws AmqpException
routingKey - the routing keymessage - a message to sendmessagePostProcessor - a processor to apply to the message before it is sent
AmqpException - if there is a problem
Object convertSendAndReceive(String exchange,
String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
throws AmqpException
exchange - the name of the exchangeroutingKey - the routing keymessage - a message to sendmessagePostProcessor - a processor to apply to the message before it is sent
AmqpException - if there is a problem
|
Spring AMQP | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||