|
|||||||||
| 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 static java.lang.String |
DEFAULT_EXCHANGE_NAME
|
protected org.apache.commons.logging.Log |
logger
Logger available to subclasses |
| Constructor Summary | |
|---|---|
RabbitAdmin(ConnectionFactory connectionFactory)
|
|
| Method Summary | |
|---|---|
void |
afterPropertiesSet()
If autoStartup is set to true, registers a callback on the
ConnectionFactory to declare all exchanges and queues in the enclosing application context. |
void |
declareBinding(org.springframework.amqp.core.Binding binding)
|
void |
declareExchange(org.springframework.amqp.core.Exchange exchange)
|
org.springframework.amqp.core.Queue |
declareQueue()
Declares a server-named exclusive, autodelete, non-durable queue. |
void |
declareQueue(org.springframework.amqp.core.Queue queue)
|
boolean |
deleteExchange(java.lang.String exchangeName)
|
boolean |
deleteQueue(java.lang.String queueName)
|
void |
deleteQueue(java.lang.String queueName,
boolean unused,
boolean empty)
|
RabbitTemplate |
getRabbitTemplate()
|
void |
initialize()
Declares all the exchanges, queues and bindings in the enclosing application context, if any. |
boolean |
isAutoStartup()
|
void |
purgeQueue(java.lang.String queueName,
boolean noWait)
|
void |
removeBinding(org.springframework.amqp.core.Binding binding)
|
void |
setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
|
void |
setAutoStartup(boolean autoStartup)
|
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
protected static final java.lang.String DEFAULT_EXCHANGE_NAME
protected final org.apache.commons.logging.Log logger
| Constructor Detail |
|---|
public RabbitAdmin(ConnectionFactory connectionFactory)
| Method Detail |
|---|
public void setAutoStartup(boolean autoStartup)
public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
setApplicationContext in interface org.springframework.context.ApplicationContextAwarepublic RabbitTemplate getRabbitTemplate()
public void declareExchange(org.springframework.amqp.core.Exchange exchange)
declareExchange in interface org.springframework.amqp.core.AmqpAdmin@ManagedOperation public boolean deleteExchange(java.lang.String exchangeName)
deleteExchange in interface org.springframework.amqp.core.AmqpAdmin@ManagedOperation public void declareQueue(org.springframework.amqp.core.Queue queue)
declareQueue in interface org.springframework.amqp.core.AmqpAdmin@ManagedOperation public org.springframework.amqp.core.Queue declareQueue()
declareQueue in interface org.springframework.amqp.core.AmqpAdmin@ManagedOperation public boolean deleteQueue(java.lang.String queueName)
deleteQueue in interface org.springframework.amqp.core.AmqpAdmin
@ManagedOperation
public void deleteQueue(java.lang.String queueName,
boolean unused,
boolean empty)
deleteQueue in interface org.springframework.amqp.core.AmqpAdmin
@ManagedOperation
public void purgeQueue(java.lang.String queueName,
boolean noWait)
purgeQueue in interface org.springframework.amqp.core.AmqpAdmin@ManagedOperation public void declareBinding(org.springframework.amqp.core.Binding binding)
declareBinding in interface org.springframework.amqp.core.AmqpAdmin@ManagedOperation public void removeBinding(org.springframework.amqp.core.Binding binding)
removeBinding in interface org.springframework.amqp.core.AmqpAdminpublic boolean isAutoStartup()
public void afterPropertiesSet()
autoStartup is set to true, registers a callback on the
ConnectionFactory to declare all exchanges and queues in the enclosing application context. If the
callback fails then it may cause other clients of the connection factory to fail, but since only exchanges,
queues and bindings are declared failure is not expected.
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanInitializingBean.afterPropertiesSet(),
initialize()public void initialize()
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||