|
|||||||||
| 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 |
protected static java.lang.Object |
QUEUE_CONSUMER_COUNT
|
protected static java.lang.Object |
QUEUE_MESSAGE_COUNT
|
protected static java.lang.Object |
QUEUE_NAME
|
| 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)
|
java.util.Properties |
getQueueProperties(java.lang.String queueName)
Returns 3 properties QUEUE_NAME, QUEUE_MESSAGE_COUNT,
QUEUE_CONSUMER_COUNT, or null if the queue doesn't exist. |
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)
|
void |
setIgnoreDeclarationExceptions(boolean ignoreDeclarationExceptions)
|
| 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 static final java.lang.Object QUEUE_NAME
protected static final java.lang.Object QUEUE_MESSAGE_COUNT
protected static final java.lang.Object QUEUE_CONSUMER_COUNT
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 void setIgnoreDeclarationExceptions(boolean ignoreDeclarationExceptions)
public 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 java.util.Properties getQueueProperties(java.lang.String queueName)
QUEUE_NAME, QUEUE_MESSAGE_COUNT,
QUEUE_CONSUMER_COUNT, or null if the queue doesn't exist.
getQueueProperties 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 | ||||||||