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(String vhost, Exchange exchange) Add an exchange to the specified vhost.
void	addQueue(Queue queue) Add a queue to the default vhost ('/').
void	addQueue(String vhost, Queue queue) Add a queue to the specified vhost.
void	deleteExchange(Exchange exchange) Delete an exchange from the default vhost ('/').
void	deleteExchange(String vhost, Exchange exchange) Delete an exchange from the provided vhost.
void	deleteQueue(Queue queue) Delete a queue from the default vhost ('/').
void	deleteQueue(String vhost, Queue queue) Delete a queue from the provided vhost.
List<Binding>	getBindings() Get all bindings.
List<Binding>	getBindings(String vhost) Get all bindings in the provided vhost.
List<Binding>	getBindingsForExchange(String vhost, String exchange) Get all bindings from the provided exchange in the provided vhost.
Exchange	getExchange(String name) Get a specific queue from the default vhost ('/').
Exchange	getExchange(String vhost, String name) Get a specific exchange from the provided vhost.
List<Exchange>	getExchanges() Get all exchanges.
List<Exchange>	getExchanges(String vhost) Get all exchanges in the provided vhost.
Queue	getQueue(String name) Get a specific queue from the default vhost ('/').
Queue	getQueue(String vhost, String name) Get a specific queue from the provided vhost.
List<Queue>	getQueues() Get all queues.
List<Queue>	getQueues(String vhost) Get all queues in the provided vhost.
void	purgeQueue(Queue queue) Purge a queue in the default vhost ('/').
void	purgeQueue(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(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(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(String vhost,
                 Queue queue)

Delete a queue from the provided vhost.

Parameters:

vhost - the vhost.

queue - the queue.

getQueue

Queue getQueue(String name)

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

Parameters:

name - the queue name.

Returns:

the Queue.

getQueue

Queue getQueue(String vhost,
               String name)

Get a specific queue from the provided vhost.

Parameters:

vhost - the vhost.

name - the queue name.

Returns:

the Queue.

getQueues

List<Queue> getQueues()

Get all queues.

Returns:

the queues.

getQueues

List<Queue> getQueues(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(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(String vhost,
                    Exchange exchange)

Delete an exchange from the provided vhost.

Parameters:

vhost - the vhost.

exchange - the queue.

getExchange

Exchange getExchange(String name)

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

Parameters:

name - the exchange name.

Returns:

the Exchange.

getExchange

Exchange getExchange(String vhost,
                     String name)

Get a specific exchange from the provided vhost.

Parameters:

vhost - the vhost.

name - the exchange name.

Returns:

the Exchange.

getExchanges

List<Exchange> getExchanges()

Get all exchanges.

Returns:

the exchanges.

getExchanges

List<Exchange> getExchanges(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

List<Binding> getBindings()

Get all bindings.

Returns:

the bindings.

getBindings

List<Binding> getBindings(String vhost)

Get all bindings in the provided vhost.

Parameters:

vhost - the vhost.

Returns:

the bindings.

getBindingsForExchange

List<Binding> getBindingsForExchange(String vhost,
                                     String exchange)

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

Parameters:

vhost - the vhost.

exchange - the exchange name.

Returns:

the bindings.