Client
usage.@Deprecated public class RabbitManagementTemplate extends 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()
Deprecated.
Construct a template using uri "localhost:15672/api/" and user guest/guest.
|
RabbitManagementTemplate(com.rabbitmq.http.client.Client rabbitClient)
Deprecated.
Construct a template using the supplied client.
|
RabbitManagementTemplate(String uri)
Deprecated.
Construct a template using the supplied uri.
|
RabbitManagementTemplate(String uri,
String username,
String password)
Deprecated.
Construct a template using the supplied uri.
|
Modifier and Type | Method and Description |
---|---|
void |
addExchange(Exchange exchange)
Deprecated.
Add an exchange to the default vhost ('/').
|
void |
addExchange(String vhost,
Exchange exchange)
Deprecated.
Add an exchange to the specified vhost.
|
void |
addQueue(Queue queue)
Deprecated.
Add a queue to the default vhost ('/').
|
void |
addQueue(String vhost,
Queue queue)
Deprecated.
Add a queue to the specified vhost.
|
void |
deleteExchange(Exchange exchange)
Deprecated.
Delete an exchange from the default vhost ('/').
|
void |
deleteExchange(String vhost,
Exchange exchange)
Deprecated.
Delete an exchange from the provided vhost.
|
void |
deleteQueue(Queue queue)
Deprecated.
Delete a queue from the default vhost ('/').
|
void |
deleteQueue(String vhost,
Queue queue)
Deprecated.
Delete a queue from the provided vhost.
|
List<Binding> |
getBindings()
Deprecated.
Get all bindings.
|
List<Binding> |
getBindings(String vhost)
Deprecated.
Get all bindings in the provided vhost.
|
List<Binding> |
getBindingsForExchange(String vhost,
String exchange)
Deprecated.
Get all bindings from the provided exchange in the provided vhost.
|
com.rabbitmq.http.client.Client |
getClient()
Deprecated.
|
Exchange |
getExchange(String name)
Deprecated.
Get a specific queue from the default vhost ('/').
|
Exchange |
getExchange(String vhost,
String name)
Deprecated.
Get a specific exchange from the provided vhost.
|
List<Exchange> |
getExchanges()
Deprecated.
Get all exchanges.
|
List<Exchange> |
getExchanges(String vhost)
Deprecated.
Get all exchanges in the provided vhost.
|
Queue |
getQueue(String name)
Deprecated.
Get a specific queue from the default vhost ('/').
|
Queue |
getQueue(String vhost,
String name)
Deprecated.
Get a specific queue from the provided vhost.
|
List<Queue> |
getQueues()
Deprecated.
Get all queues.
|
List<Queue> |
getQueues(String vhost)
Deprecated.
Get all queues in the provided vhost.
|
void |
purgeQueue(Queue queue)
Deprecated.
Purge a queue in the default vhost ('/').
|
void |
purgeQueue(String vhost,
Queue queue)
Deprecated.
Purge a queue in the provided vhost.
|
public RabbitManagementTemplate()
public RabbitManagementTemplate(com.rabbitmq.http.client.Client rabbitClient)
rabbitClient
- the client.public RabbitManagementTemplate(String uri)
uri
- the uri - must include user info, e.g.
"http://guest:guest@localhost:15672/api/".public com.rabbitmq.http.client.Client getClient()
public void addExchange(Exchange exchange)
AmqpManagementOperations
addExchange
in interface AmqpManagementOperations
exchange
- the exchange.public void addExchange(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(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(String vhost, Queue queue)
AmqpManagementOperations
deleteQueue
in interface AmqpManagementOperations
vhost
- the vhost.queue
- the queue.public Queue getQueue(String name)
AmqpManagementOperations
getQueue
in interface AmqpManagementOperations
name
- the queue name.public Queue getQueue(String vhost, String name)
AmqpManagementOperations
getQueue
in interface AmqpManagementOperations
vhost
- the vhost.name
- the queue name.public List<Queue> getQueues()
AmqpManagementOperations
getQueues
in interface AmqpManagementOperations
public List<Queue> getQueues(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(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(String vhost, Exchange exchange)
AmqpManagementOperations
deleteExchange
in interface AmqpManagementOperations
vhost
- the vhost.exchange
- the queue.public Exchange getExchange(String name)
AmqpManagementOperations
getExchange
in interface AmqpManagementOperations
name
- the exchange name.public Exchange getExchange(String vhost, String name)
AmqpManagementOperations
getExchange
in interface AmqpManagementOperations
vhost
- the vhost.name
- the exchange name.public List<Exchange> getExchanges()
AmqpManagementOperations
getExchanges
in interface AmqpManagementOperations
public List<Exchange> getExchanges(String vhost)
AmqpManagementOperations
DirectExchange
,
FanoutExchange
, HeadersExchange
and TopicExchange
s
are returned.getExchanges
in interface AmqpManagementOperations
vhost
- the vhost.public List<Binding> getBindings()
AmqpManagementOperations
getBindings
in interface AmqpManagementOperations
public List<Binding> getBindings(String vhost)
AmqpManagementOperations
getBindings
in interface AmqpManagementOperations
vhost
- the vhost.public List<Binding> getBindingsForExchange(String vhost, String exchange)
AmqpManagementOperations
getBindingsForExchange
in interface AmqpManagementOperations
vhost
- the vhost.exchange
- the exchange name.