Spring AMQP

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(Object message, MessagePostProcessor messagePostProcessor)
           
 Object convertSendAndReceive(String routingKey, Object message)
           
 Object convertSendAndReceive(String routingKey, Object message, MessagePostProcessor messagePostProcessor)
           
 Object convertSendAndReceive(String exchange, String routingKey, Object message)
           
 Object convertSendAndReceive(String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor)
           
 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)
           
 

Method Detail

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

convertSendAndReceive

Object convertSendAndReceive(Object message,
                             MessagePostProcessor messagePostProcessor)
                             throws AmqpException
Throws:
AmqpException

convertSendAndReceive

Object convertSendAndReceive(String routingKey,
                             Object message,
                             MessagePostProcessor messagePostProcessor)
                             throws AmqpException
Throws:
AmqpException

convertSendAndReceive

Object convertSendAndReceive(String exchange,
                             String routingKey,
                             Object message,
                             MessagePostProcessor messagePostProcessor)
                             throws AmqpException
Throws:
AmqpException

Spring AMQP

Copyright © 2011. All Rights Reserved.