ManagementClientAsync Class
Definition
- java.lang.Object
- com.microsoft.azure.servicebus.management.ManagementClientAsync
Asynchronous client to perform management operations on Service Bus entities. Operations return CompletableFuture which asynchronously return the responses.
public class ManagementClientAsyncConstructors
| ManagementClientAsync(ConnectionStringBuilder connectionStringBuilder) |
Creates a new ManagementClientAsync. User should call close() at the end of life of the client. |
| ManagementClientAsync(URI namespaceEndpointURI, ClientSettings clientSettings) |
Creates a new ManagementClientAsync. User should call close() at the end of life of the client. |
Methods
| close() |
Disposes and closes the managementClient. |
| createQueueAsync(QueueDescription queueDescription) |
Creates a new queue in the service namespace with the given name. See QueueDescription for default values of queue properties. |
| createQueueAsync(String queuePath) |
Creates a new queue in the service namespace with the given name. See QueueDescription for default values of queue properties. |
| createRuleAsync(String topicName, String subscriptionName, RuleDescription ruleDescription) |
Creates a new rule for a given topic - subscription. See RuleDescription for default values of subscription properties. |
| createSubscriptionAsync(SubscriptionDescription subscriptionDescription) |
Creates a new subscription in the service namespace with the given name. See SubscriptionDescription for default values of subscription properties. |
| createSubscriptionAsync(SubscriptionDescription subscriptionDescription, RuleDescription defaultRule) |
Creates a new subscription in the service namespace with the provided default rule. See SubscriptionDescription for default values of subscription properties. |
| createSubscriptionAsync(String topicPath, String subscriptionName) |
Creates a new subscription for a given topic in the service namespace with the given name. See SubscriptionDescription for default values of subscription properties. |
| createTopicAsync(TopicDescription topicDescription) |
Creates a new topic in the service namespace with the given name. See TopicDescription for default values of topic properties. |
| createTopicAsync(String topicPath) |
Creates a new topic in the service namespace with the given name. See TopicDescription for default values of topic properties. |
| deleteQueueAsync(String path) |
Deletes the queue described by the path relative to the service namespace base address. |
| deleteRuleAsync(String topicPath, String subscriptionName, String ruleName) |
Deletes the rule for a given topic-subscription. |
| deleteSubscriptionAsync(String topicPath, String subscriptionName) |
Deletes the subscription described by the topicPath and the subscriptionName. |
| deleteTopicAsync(String path) |
Deletes the topic described by the path relative to the service namespace base address. |
| getNamespaceInfoAsync() |
Retrieves information related to the namespace. Works with any claim (Send/Listen/Manage). |
| getQueueAsync(String path) |
Retrieves a queue from the service namespace |
| getQueueRuntimeInfoAsync(String path) |
Retrieves the runtime information of a queue. |
| getQueuesAsync() |
Retrieves the list of queues present in the namespace. |
| getQueuesAsync(int count, int skip) |
Retrieves the list of queues present in the namespace. You can simulate pages of list of entities by manipulating count and skip parameters. skip(0)+count(100) gives first 100 entities. skip(100)+count(100) gives the next 100 entities. |
| getRuleAsync(String topicPath, String subscriptionName, String ruleName) |
Retrieves a rule for a given topic and subscription from the service namespace |
| getRulesAsync(String topicName, String subscriptionName) |
Retrieves the list of rules for a given topic-subscription in the namespace. |
| getRulesAsync(String topicName, String subscriptionName, int count, int skip) |
Retrieves the list of rules for a given topic-subscription in the namespace. You can simulate pages of list of entities by manipulating count and skip parameters. skip(0)+count(100) gives first 100 entities. skip(100)+count(100) gives the next 100 entities. |
| getSubscriptionAsync(String topicPath, String subscriptionName) |
Retrieves a subscription for a given topic from the service namespace |
| getSubscriptionRuntimeInfoAsync(String topicPath, String subscriptionName) |
Retrieves the runtime information of a subscription in a given topic |
| getSubscriptionsAsync(String topicName) |
Retrieves the list of subscriptions for a given topic in the namespace. |
| getSubscriptionsAsync(String topicName, int count, int skip) |
Retrieves the list of subscriptions for a given topic in the namespace. You can simulate pages of list of entities by manipulating count and skip parameters. skip(0)+count(100) gives first 100 entities. skip(100)+count(100) gives the next 100 entities. |
| getTopicAsync(String path) |
Retrieves a topic from the service namespace |
| getTopicRuntimeInfoAsync(String path) |
Retrieves the runtime information of a topic |
| getTopicsAsync() |
Retrieves the list of topics present in the namespace. |
| getTopicsAsync(int count, int skip) |
Retrieves the list of topics present in the namespace. You can simulate pages of list of entities by manipulating count and skip parameters. skip(0)+count(100) gives first 100 entities. skip(100)+count(100) gives the next 100 entities. |
| queueExistsAsync(String path) |
Checks whether a given queue exists or not. |
| ruleExistsAsync(String topicPath, String subscriptionName, String ruleName) |
Checks whether a given rule exists or not for a given subscription. |
| subscriptionExistsAsync(String topicPath, String subscriptionName) |
Checks whether a given subscription exists or not. |
| topicExistsAsync(String path) |
Checks whether a given topic exists or not. |
| updateQueueAsync(QueueDescription queueDescription) |
Updates an existing queue. |
| updateRuleAsync(String topicName, String subscriptionName, RuleDescription ruleDescription) |
Updates an existing rule. |
| updateSubscriptionAsync(SubscriptionDescription subscriptionDescription) |
Updates an existing subscription. |
| updateTopicAsync(TopicDescription topicDescription) |
Updates an existing topic. |