org.springframework.amqp.core

Interface AmqpManagementOperations

All Known Implementing Classes:

RabbitManagementTemplate

public interface AmqpManagementOperations

Interface specifying management operations.

Since:

1.5

Author:

Gary Russell

Method Summary

Modifier and Type	Method and Description
void	addExchange(Exchange exchange) Add an exchange to the default vhost ('/').
void	addExchange(java.lang.String vhost, Exchange exchange) Add an exchange to the specified vhost.
void	addQueue(Queue queue) Add a queue to the default vhost ('/').
void	addQueue(java.lang.String vhost, Queue queue) Add a queue to the specified vhost.
void	deleteExchange(Exchange exchange) Delete an exchange from the default vhost ('/').
void	deleteExchange(java.lang.String vhost, Exchange exchange) Delete an exchange from the provided vhost.
void	deleteQueue(Queue queue) Delete a queue from the default vhost ('/').
void	deleteQueue(java.lang.String vhost, Queue queue) Delete a queue from the provided vhost.
java.util.List<Binding>	getBindings() Get all bindings.
java.util.List<Binding>	getBindings(java.lang.String vhost) Get all bindings in the provided vhost.
java.util.List<Binding>	getBindingsForExchange(java.lang.String vhost, java.lang.String exchange) Get all bindings from the provided exchange in the provided vhost.
Exchange	getExchange(java.lang.String name) Get a specific queue from the default vhost ('/').
Exchange	getExchange(java.lang.String vhost, java.lang.String name) Get a specific exchange from the provided vhost.
java.util.List<Exchange>	getExchanges() Get all exchanges.
java.util.List<Exchange>	getExchanges(java.lang.String vhost) Get all exchanges in the provided vhost.
Queue	getQueue(java.lang.String name) Get a specific queue from the default vhost ('/').
Queue	getQueue(java.lang.String vhost, java.lang.String name) Get a specific queue from the provided vhost.
java.util.List<Queue>	getQueues() Get all queues.
java.util.List<Queue>	getQueues(java.lang.String vhost) Get all queues in the provided vhost.
void	purgeQueue(Queue queue) Purge a queue in the default vhost ('/').
void	purgeQueue(java.lang.String vhost, Queue queue) Purge a queue in the provided vhost.

Method Detail

addExchange

void addExchange(Exchange exchange)

Add an exchange to the default vhost ('/').

Parameters:

exchange - the exchange.

addExchange

void addExchange(java.lang.String vhost,
                 Exchange exchange)

Add an exchange to the specified vhost.

Parameters:

vhost - the vhost.

exchange - the exchange.

purgeQueue

void purgeQueue(Queue queue)

Purge a queue in the default vhost ('/').

Parameters:

queue - the queue.

purgeQueue

void purgeQueue(java.lang.String vhost,
                Queue queue)

Purge a queue in the provided vhost.

Parameters:

vhost - the vhost.

queue - the queue.

deleteQueue

void deleteQueue(Queue queue)

Delete a queue from the default vhost ('/').

Parameters:

queue - the queue.

deleteQueue

void deleteQueue(java.lang.String vhost,
                 Queue queue)

Delete a queue from the provided vhost.

Parameters:

vhost - the vhost.

queue - the queue.

getQueue

Queue getQueue(java.lang.String name)

Get a specific queue from the default vhost ('/').

Parameters:

name - the queue name.

Returns:

the Queue.

getQueue

Queue getQueue(java.lang.String vhost,
               java.lang.String name)

Get a specific queue from the provided vhost.

Parameters:

vhost - the vhost.

name - the queue name.

Returns:

the Queue.

getQueues

java.util.List<Queue> getQueues()

Get all queues.

Returns:

the queues.

getQueues

java.util.List<Queue> getQueues(java.lang.String vhost)

Get all queues in the provided vhost.

Parameters:

vhost - the vhost.

Returns:

the queues.

addQueue

void addQueue(Queue queue)

Add a queue to the default vhost ('/').

Parameters:

queue - the queue.

addQueue

void addQueue(java.lang.String vhost,
              Queue queue)

Add a queue to the specified vhost.

Parameters:

vhost - the vhost.

queue - the queue.

deleteExchange

void deleteExchange(Exchange exchange)

Delete an exchange from the default vhost ('/').

Parameters:

exchange - the queue.

deleteExchange

void deleteExchange(java.lang.String vhost,
                    Exchange exchange)

Delete an exchange from the provided vhost.

Parameters:

vhost - the vhost.

exchange - the queue.

getExchange

Exchange getExchange(java.lang.String name)

Get a specific queue from the default vhost ('/').

Parameters:

name - the exchange name.

Returns:

the Exchange.

getExchange

Exchange getExchange(java.lang.String vhost,
                     java.lang.String name)

Get a specific exchange from the provided vhost.

Parameters:

vhost - the vhost.

name - the exchange name.

Returns:

the Exchange.

getExchanges

java.util.List<Exchange> getExchanges()

Get all exchanges.

Returns:

the exchanges.

getExchanges

java.util.List<Exchange> getExchanges(java.lang.String vhost)

Get all exchanges in the provided vhost. Only DirectExchange, FanoutExchange, HeadersExchange and TopicExchanges are returned.

Parameters:

vhost - the vhost.

Returns:

the exchanges.

getBindings

java.util.List<Binding> getBindings()

Get all bindings.

Returns:

the bindings.

getBindings

java.util.List<Binding> getBindings(java.lang.String vhost)

Get all bindings in the provided vhost.

Parameters:

vhost - the vhost.

Returns:

the bindings.

getBindingsForExchange

java.util.List<Binding> getBindingsForExchange(java.lang.String vhost,
                                               java.lang.String exchange)

Get all bindings from the provided exchange in the provided vhost.

Parameters:

vhost - the vhost.

exchange - the exchange name.

Returns:

the bindings.