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 an receive methods. The convertAndSend and receiveAndConvert
methods allow let you send and receive POJO objects. Implementations are expected to
delegate to an instance of org.springframework.support.converter.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)
|
Message |
receive()
|
Message |
receive(String queueName)
|
Object |
receiveAndConvert()
|
Object |
receiveAndConvert(String queueName)
|
void |
send(MessageCreator messageCreator)
|
void |
send(String routingKey,
MessageCreator messageCreator)
|
void |
send(String exchange,
String routingKey,
MessageCreator messageCreator)
|
send
void send(MessageCreator messageCreator)
throws AmqpException
- Throws:
AmqpException
send
void send(String routingKey,
MessageCreator messageCreator)
throws AmqpException
- Throws:
AmqpException
send
void send(String exchange,
String routingKey,
MessageCreator messageCreator)
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
Copyright © 2010. All Rights Reserved.