|
Spring AMQP | |||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.springframework.amqp.rabbit.core.RabbitAdmin
public class RabbitAdmin
RabbitMQ implementation of portable AMQP administrative operations for AMQP >= 0.9.1
| Field Summary | |
|---|---|
protected org.apache.commons.logging.Log |
logger
Logger available to subclasses |
| Constructor Summary | |
|---|---|
RabbitAdmin()
|
|
RabbitAdmin(ConnectionFactory connectionFactory)
|
|
RabbitAdmin(RabbitTemplate rabbitTemplate)
|
|
| Method Summary | |
|---|---|
void |
afterPropertiesSet()
|
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 |
RabbitTemplate |
getRabbitTemplate()
|
void |
purgeQueue(String queueName,
boolean noWait)
Purges the contents of the given queue. |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
protected final org.apache.commons.logging.Log logger
| Constructor Detail |
|---|
public RabbitAdmin()
public RabbitAdmin(ConnectionFactory connectionFactory)
public RabbitAdmin(RabbitTemplate rabbitTemplate)
| Method Detail |
|---|
public RabbitTemplate getRabbitTemplate()
public void afterPropertiesSet()
afterPropertiesSet in interface InitializingBeanpublic void declareExchange(Exchange exchange)
AmqpAdmin
declareExchange in interface AmqpAdminexchange - the exchange to declare.@ManagedOperation public void deleteExchange(String exchangeName)
AmqpAdmin
deleteExchange in interface AmqpAdminexchangeName - the name of the exchange@ManagedOperation public void declareQueue(Queue queue)
AmqpAdmin
declareQueue in interface AmqpAdminqueue - the queue to declare@ManagedOperation public Queue declareQueue()
AmqpAdmin
declareQueue in interface AmqpAdmin@ManagedOperation public void deleteQueue(String queueName)
AmqpAdmin
deleteQueue in interface AmqpAdminqueueName - the name of the queue
@ManagedOperation
public void deleteQueue(String queueName,
boolean unused,
boolean empty)
AmqpAdmin
deleteQueue in interface AmqpAdminqueueName - the name of the queueunused - true if the queue should be deleted only if not in useempty - true if the queue should be deleted only if empty
@ManagedOperation
public void purgeQueue(String queueName,
boolean noWait)
AmqpAdmin
purgeQueue in interface AmqpAdminqueueName - the name of the queuenoWait - true to not await completion of the purge@ManagedOperation public void declareBinding(Binding binding)
AmqpAdmin
declareBinding in interface AmqpAdminbinding - a description of the binding to declare.
|
Spring AMQP | |||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||