public class RabbitManagementTemplate extends java.lang.Object implements AmqpManagementOperations
Client
providing convenient access to
the REST methods using the familiar Spring AMQP domain objects for Queue
,
Exchange
and Binding
. For more complete access, including access to
properties not available in the Spring AMQP domain classes, use the Client
directly.Constructor and Description |
---|
RabbitManagementTemplate()
Construct a template using uri "localhost:15672/api/" and user guest/guest.
|
RabbitManagementTemplate(com.rabbitmq.http.client.Client rabbitClient)
Construct a template using the supplied client.
|
RabbitManagementTemplate(java.lang.String uri)
Construct a template using the supplied uri.
|
RabbitManagementTemplate(java.lang.String uri,
java.lang.String username,
java.lang.String password)
Construct a template using the supplied uri.
|
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.
|
com.rabbitmq.http.client.Client |
getClient() |
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.
|
public RabbitManagementTemplate()
public RabbitManagementTemplate(com.rabbitmq.http.client.Client rabbitClient)
rabbitClient
- the client.public RabbitManagementTemplate(java.lang.String uri)
uri
- the uri - must include user info, e.g.
"http://guest:guest@localhost:15672/api/".public RabbitManagementTemplate(java.lang.String uri, java.lang.String username, java.lang.String password)
uri
- the uri.username
- the user.password
- the password.public com.rabbitmq.http.client.Client getClient()
public void addExchange(Exchange exchange)
AmqpManagementOperations
addExchange
in interface AmqpManagementOperations
exchange
- the exchange.public void addExchange(java.lang.String vhost, Exchange exchange)
AmqpManagementOperations
addExchange
in interface AmqpManagementOperations
vhost
- the vhost.exchange
- the exchange.public void purgeQueue(Queue queue)
AmqpManagementOperations
purgeQueue
in interface AmqpManagementOperations
queue
- the queue.public void purgeQueue(java.lang.String vhost, Queue queue)
AmqpManagementOperations
purgeQueue
in interface AmqpManagementOperations
vhost
- the vhost.queue
- the queue.public void deleteQueue(Queue queue)
AmqpManagementOperations
deleteQueue
in interface AmqpManagementOperations
queue
- the queue.public void deleteQueue(java.lang.String vhost, Queue queue)
AmqpManagementOperations
deleteQueue
in interface AmqpManagementOperations
vhost
- the vhost.queue
- the queue.public Queue getQueue(java.lang.String name)
AmqpManagementOperations
getQueue
in interface AmqpManagementOperations
name
- the queue name.public Queue getQueue(java.lang.String vhost, java.lang.String name)
AmqpManagementOperations
getQueue
in interface AmqpManagementOperations
vhost
- the vhost.name
- the queue name.public java.util.List<Queue> getQueues()
AmqpManagementOperations
getQueues
in interface AmqpManagementOperations
public java.util.List<Queue> getQueues(java.lang.String vhost)
AmqpManagementOperations
getQueues
in interface AmqpManagementOperations
vhost
- the vhost.public void addQueue(Queue queue)
AmqpManagementOperations
addQueue
in interface AmqpManagementOperations
queue
- the queue.public void addQueue(java.lang.String vhost, Queue queue)
AmqpManagementOperations
addQueue
in interface AmqpManagementOperations
vhost
- the vhost.queue
- the queue.public void deleteExchange(Exchange exchange)
AmqpManagementOperations
deleteExchange
in interface AmqpManagementOperations
exchange
- the queue.public void deleteExchange(java.lang.String vhost, Exchange exchange)
AmqpManagementOperations
deleteExchange
in interface AmqpManagementOperations
vhost
- the vhost.exchange
- the queue.public Exchange getExchange(java.lang.String name)
AmqpManagementOperations
getExchange
in interface AmqpManagementOperations
name
- the exchange name.public Exchange getExchange(java.lang.String vhost, java.lang.String name)
AmqpManagementOperations
getExchange
in interface AmqpManagementOperations
vhost
- the vhost.name
- the exchange name.public java.util.List<Exchange> getExchanges()
AmqpManagementOperations
getExchanges
in interface AmqpManagementOperations
public java.util.List<Exchange> getExchanges(java.lang.String vhost)
AmqpManagementOperations
DirectExchange
,
FanoutExchange
, HeadersExchange
and TopicExchange
s
are returned.getExchanges
in interface AmqpManagementOperations
vhost
- the vhost.public java.util.List<Binding> getBindings()
AmqpManagementOperations
getBindings
in interface AmqpManagementOperations
public java.util.List<Binding> getBindings(java.lang.String vhost)
AmqpManagementOperations
getBindings
in interface AmqpManagementOperations
vhost
- the vhost.public java.util.List<Binding> getBindingsForExchange(java.lang.String vhost, java.lang.String exchange)
AmqpManagementOperations
getBindingsForExchange
in interface AmqpManagementOperations
vhost
- the vhost.exchange
- the exchange name.