| Package | Description |
|---|---|
| io.openmessaging |
| Modifier and Type | Method and Description |
|---|---|
void |
ResourceManager.createQueue(String queueName,
KeyValue attributes)
Creates a
Queue resource in the configured namespace with some preset attributes. |
void |
ResourceManager.createRouting(String routingName,
KeyValue attributes)
Creates a
Routing resource in the configured namespace with some preset attributes. |
void |
ResourceManager.deleteNamespace(String nsName)
Deletes an existing namespace resource.
|
void |
ResourceManager.deleteQueue(String queueName)
Deletes an existing queue resource.
|
void |
ResourceManager.deleteRouting(String routingName)
Deletes an existing routing resource.
|
KeyValue |
ResourceManager.getNamespaceAttributes(String nsName)
Gets the attributes of the specific namespace.
|
KeyValue |
ResourceManager.getQueueAttributes(String queueName)
Gets the attributes of the specified queue.
|
KeyValue |
ResourceManager.getRoutingAttributes(String routingName)
Gets the attributes of the specified routing.
|
List<String> |
ResourceManager.listQueues(String nsName)
Gets the queue list in the specific namespace.
|
List<String> |
ResourceManager.listRoutings(String nsName)
Gets the routing list in the specific namespace.
|
List<String> |
ResourceManager.listStreams(String queueName)
Gets the stream list behind the specified queue.
|
void |
ResourceManager.setNamespaceAttributes(String nsName,
KeyValue attributes)
Sets the attributes of the specific namespace, the old attributes will be replaced
by the provided attributes, only the provided key will be updated.
|
void |
ResourceManager.setQueueAttributes(String queueName,
KeyValue attributes)
Sets the attributes of the specified queue, the old attributes will be replaced
by the provided attributes, only the provided key will be updated.
|
void |
ResourceManager.setRoutingAttributes(String routingName,
KeyValue attributes)
Sets the attributes of the specified routing, the old attributes will be replaced
by the provided attributes, only the provided key will be updated.
|
void |
ResourceManager.updateMessage(String queueName,
String messageId,
KeyValue headers)
Updates some system headers of a message in the configured namespace.
|
Copyright © 2017–2018 OpenMessaging. All rights reserved.