Spring AMQP

org.springframework.amqp.core
Interface AmqpAdmin

All Known Subinterfaces:
RabbitBrokerOperations
All Known Implementing Classes:
RabbitAdmin, RabbitBrokerAdmin

public interface AmqpAdmin

Specifies a basic set of portable AMQP administrative operations for AMQP > 0.8

Author:
Mark Pollack

Method Summary
 void declareBinding(Binding binding)
          Declare a binding of a queue to an exchange.
 void declareExchange(Exchange exchange)
          Declare an exchange
 Queue declareQueue()
          Declare a queue whose name is automatically named.
 void declareQueue(Queue queue)
          Declare the given queue
 void deleteExchange(String exchangeName)
          Delete an exchange.
 void deleteQueue(String queueName)
          Delete a queue, without regard for whether it is in use or has messages on it
 void deleteQueue(String queueName, boolean unused, boolean empty)
          Delete a queue
 void purgeQueue(String queueName, boolean noWait)
          Purges the contents of the given queue.
 

Method Detail

declareExchange

void declareExchange(Exchange exchange)
Declare an exchange

Parameters:
exchange - the exchange to declare.

deleteExchange

void deleteExchange(String exchangeName)
Delete an exchange. Look at implementation specific subclass for implementation specific behavior, for example for RabbitMQ this will delete the exchange without regard for whether it is in use or not.

Parameters:
exchangeName - the name of the exchange

declareQueue

Queue declareQueue()
Declare a queue whose name is automatically named. It is created with exclusive = true, autoDelete=true, and durable = false.


declareQueue

void declareQueue(Queue queue)
Declare the given queue

Parameters:
queue - the queue to declare

deleteQueue

void deleteQueue(String queueName)
Delete a queue, without regard for whether it is in use or has messages on it

Parameters:
queueName - the name of the queue

deleteQueue

void deleteQueue(String queueName,
                 boolean unused,
                 boolean empty)
Delete a queue

Parameters:
queueName - the name of the queue
unused - true if the queue should be deleted only if not in use
empty - true if the queue should be deleted only if empty

purgeQueue

void purgeQueue(String queueName,
                boolean noWait)
Purges the contents of the given queue.

Parameters:
queueName - the name of the queue
noWait - true to not await completion of the purge

declareBinding

void declareBinding(Binding binding)
Declare a binding of a queue to an exchange.

Parameters:
binding - a description of the binding to declare.

Spring AMQP

Copyright © 2010. All Rights Reserved.