public class RabbitManagementTemplate
extends java.lang.Object
implements org.springframework.amqp.core.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,
java.lang.String username,
java.lang.String password)
Construct a template using the supplied uri.
|
| Modifier and Type | Method and Description |
|---|---|
void |
addExchange(org.springframework.amqp.core.Exchange exchange) |
void |
addExchange(java.lang.String vhost,
org.springframework.amqp.core.Exchange exchange) |
void |
addQueue(org.springframework.amqp.core.Queue queue) |
void |
addQueue(java.lang.String vhost,
org.springframework.amqp.core.Queue queue) |
void |
deleteExchange(org.springframework.amqp.core.Exchange exchange) |
void |
deleteExchange(java.lang.String vhost,
org.springframework.amqp.core.Exchange exchange) |
void |
deleteQueue(org.springframework.amqp.core.Queue queue) |
void |
deleteQueue(java.lang.String vhost,
org.springframework.amqp.core.Queue queue) |
java.util.List<org.springframework.amqp.core.Binding> |
getBindings() |
java.util.List<org.springframework.amqp.core.Binding> |
getBindings(java.lang.String vhost) |
java.util.List<org.springframework.amqp.core.Binding> |
getBindingsForExchange(java.lang.String vhost,
java.lang.String exchange) |
com.rabbitmq.http.client.Client |
getClient() |
org.springframework.amqp.core.Exchange |
getExchange(java.lang.String name) |
org.springframework.amqp.core.Exchange |
getExchange(java.lang.String vhost,
java.lang.String name) |
java.util.List<org.springframework.amqp.core.Exchange> |
getExchanges() |
java.util.List<org.springframework.amqp.core.Exchange> |
getExchanges(java.lang.String vhost) |
org.springframework.amqp.core.Queue |
getQueue(java.lang.String name) |
org.springframework.amqp.core.Queue |
getQueue(java.lang.String vhost,
java.lang.String name) |
java.util.List<org.springframework.amqp.core.Queue> |
getQueues() |
java.util.List<org.springframework.amqp.core.Queue> |
getQueues(java.lang.String vhost) |
void |
purgeQueue(org.springframework.amqp.core.Queue queue) |
void |
purgeQueue(java.lang.String vhost,
org.springframework.amqp.core.Queue queue) |
public RabbitManagementTemplate()
public RabbitManagementTemplate(com.rabbitmq.http.client.Client rabbitClient)
rabbitClient - the client.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(org.springframework.amqp.core.Exchange exchange)
addExchange in interface org.springframework.amqp.core.AmqpManagementOperationspublic void addExchange(java.lang.String vhost,
org.springframework.amqp.core.Exchange exchange)
addExchange in interface org.springframework.amqp.core.AmqpManagementOperationspublic void purgeQueue(org.springframework.amqp.core.Queue queue)
purgeQueue in interface org.springframework.amqp.core.AmqpManagementOperationspublic void purgeQueue(java.lang.String vhost,
org.springframework.amqp.core.Queue queue)
purgeQueue in interface org.springframework.amqp.core.AmqpManagementOperationspublic void deleteQueue(org.springframework.amqp.core.Queue queue)
deleteQueue in interface org.springframework.amqp.core.AmqpManagementOperationspublic void deleteQueue(java.lang.String vhost,
org.springframework.amqp.core.Queue queue)
deleteQueue in interface org.springframework.amqp.core.AmqpManagementOperationspublic org.springframework.amqp.core.Queue getQueue(java.lang.String name)
getQueue in interface org.springframework.amqp.core.AmqpManagementOperationspublic org.springframework.amqp.core.Queue getQueue(java.lang.String vhost,
java.lang.String name)
getQueue in interface org.springframework.amqp.core.AmqpManagementOperationspublic java.util.List<org.springframework.amqp.core.Queue> getQueues()
getQueues in interface org.springframework.amqp.core.AmqpManagementOperationspublic java.util.List<org.springframework.amqp.core.Queue> getQueues(java.lang.String vhost)
getQueues in interface org.springframework.amqp.core.AmqpManagementOperationspublic void addQueue(org.springframework.amqp.core.Queue queue)
addQueue in interface org.springframework.amqp.core.AmqpManagementOperationspublic void addQueue(java.lang.String vhost,
org.springframework.amqp.core.Queue queue)
addQueue in interface org.springframework.amqp.core.AmqpManagementOperationspublic void deleteExchange(org.springframework.amqp.core.Exchange exchange)
deleteExchange in interface org.springframework.amqp.core.AmqpManagementOperationspublic void deleteExchange(java.lang.String vhost,
org.springframework.amqp.core.Exchange exchange)
deleteExchange in interface org.springframework.amqp.core.AmqpManagementOperationspublic org.springframework.amqp.core.Exchange getExchange(java.lang.String name)
getExchange in interface org.springframework.amqp.core.AmqpManagementOperationspublic org.springframework.amqp.core.Exchange getExchange(java.lang.String vhost,
java.lang.String name)
getExchange in interface org.springframework.amqp.core.AmqpManagementOperationspublic java.util.List<org.springframework.amqp.core.Exchange> getExchanges()
getExchanges in interface org.springframework.amqp.core.AmqpManagementOperationspublic java.util.List<org.springframework.amqp.core.Exchange> getExchanges(java.lang.String vhost)
getExchanges in interface org.springframework.amqp.core.AmqpManagementOperationspublic java.util.List<org.springframework.amqp.core.Binding> getBindings()
getBindings in interface org.springframework.amqp.core.AmqpManagementOperationspublic java.util.List<org.springframework.amqp.core.Binding> getBindings(java.lang.String vhost)
getBindings in interface org.springframework.amqp.core.AmqpManagementOperationspublic java.util.List<org.springframework.amqp.core.Binding> getBindingsForExchange(java.lang.String vhost,
java.lang.String exchange)
getBindingsForExchange in interface org.springframework.amqp.core.AmqpManagementOperations