org.springframework.amqp.core
Interface AmqpTemplate
- All Known Subinterfaces:
- RabbitOperations
- All Known Implementing Classes:
- RabbitTemplate
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
Method Summary |
void |
convertAndSend(Object message)
|
void |
convertAndSend(Object message,
MessagePostProcessor messagePostProcessor)
|
void |
convertAndSend(String routingKey,
Object message)
|
void |
convertAndSend(String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
|
void |
convertAndSend(String exchange,
String routingKey,
Object message)
|
void |
convertAndSend(String exchange,
String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
|
Object |
convertSendAndReceive(Object message)
|
Object |
convertSendAndReceive(String routingKey,
Object message)
|
Object |
convertSendAndReceive(String exchange,
String routingKey,
Object message)
|
Message |
receive()
|
Message |
receive(String queueName)
|
Object |
receiveAndConvert()
|
Object |
receiveAndConvert(String queueName)
|
void |
send(Message message)
|
void |
send(String routingKey,
Message message)
|
void |
send(String exchange,
String routingKey,
Message message)
|
Message |
sendAndReceive(Message message)
|
Message |
sendAndReceive(String routingKey,
Message message)
|
Message |
sendAndReceive(String exchange,
String routingKey,
Message message)
|
send
void send(Message message)
throws AmqpException
- Throws:
AmqpException
send
void send(String routingKey,
Message message)
throws AmqpException
- Throws:
AmqpException
send
void send(String exchange,
String routingKey,
Message message)
throws AmqpException
- Throws:
AmqpException
convertAndSend
void convertAndSend(Object message)
throws AmqpException
- Throws:
AmqpException
convertAndSend
void convertAndSend(String routingKey,
Object message)
throws AmqpException
- Throws:
AmqpException
convertAndSend
void convertAndSend(String exchange,
String routingKey,
Object message)
throws AmqpException
- Throws:
AmqpException
convertAndSend
void convertAndSend(Object message,
MessagePostProcessor messagePostProcessor)
throws AmqpException
- Throws:
AmqpException
convertAndSend
void convertAndSend(String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
throws AmqpException
- Throws:
AmqpException
convertAndSend
void convertAndSend(String exchange,
String routingKey,
Object message,
MessagePostProcessor messagePostProcessor)
throws AmqpException
- Throws:
AmqpException
receive
Message receive()
throws AmqpException
- Throws:
AmqpException
receive
Message receive(String queueName)
throws AmqpException
- Throws:
AmqpException
receiveAndConvert
Object receiveAndConvert()
throws AmqpException
- Throws:
AmqpException
receiveAndConvert
Object receiveAndConvert(String queueName)
throws AmqpException
- Throws:
AmqpException
sendAndReceive
Message sendAndReceive(Message message)
throws AmqpException
- Throws:
AmqpException
sendAndReceive
Message sendAndReceive(String routingKey,
Message message)
throws AmqpException
- Throws:
AmqpException
sendAndReceive
Message sendAndReceive(String exchange,
String routingKey,
Message message)
throws AmqpException
- Throws:
AmqpException
convertSendAndReceive
Object convertSendAndReceive(Object message)
throws AmqpException
- Throws:
AmqpException
convertSendAndReceive
Object convertSendAndReceive(String routingKey,
Object message)
throws AmqpException
- Throws:
AmqpException
convertSendAndReceive
Object convertSendAndReceive(String exchange,
String routingKey,
Object message)
throws AmqpException
- Throws:
AmqpException
Copyright © 2011. All Rights Reserved.