public final class ServiceBusAdministrationAsyncClient extends Object
ServiceBusAdministrationClientBuilder
.
Create a queue
// `.subscribe()` is a non-blocking call. It'll move onto the next // instruction after setting up the `consumer` and `errorConsumer` callbacks. client.createQueue("my-new-queue").subscribe(queue -> { System.out.printf("Queue created. Name: %s. Lock Duration: %s.%n", queue.getName(), queue.getLockDuration()); }, error -> { System.err.println("Error creating queue: " + error); });
Edit an existing subscription
// To update the subscription we have to: // 1. Get the subscription info from the service. // 2. Update the SubscriptionProperties we want to change. // 3. Call the updateSubscription() with the updated object. // `.subscribe()` is a non-blocking call. It'll move onto the next // instruction after setting up the `consumer` and `errorConsumer` callbacks. client.getSubscription("my-topic", "my-subscription") .flatMap(subscription -> { System.out.println("Original delivery count: " + subscription.getMaxDeliveryCount()); // Updating it to a new value. subscription.setMaxDeliveryCount(5); // Persisting the updates to the subscription object. return client.updateSubscription(subscription); }) .subscribe(subscription -> { System.out.printf("Subscription updated. Name: %s. Delivery count: %s.%n", subscription.getSubscriptionName(), subscription.getMaxDeliveryCount()); }, error -> { System.err.println("Error updating subscription: " + error); });
List all queues
// `.subscribe()` is a non-blocking call. It'll move onto the next // instruction after setting up the `consumer` and `errorConsumer` callbacks. client.listQueues().subscribe(queue -> { System.out.printf("Queue [%s]. Lock Duration: %s.%n", queue.getName(), queue.getLockDuration()); }, error -> { System.err.println("Error fetching queues: " + error); });
Modifier and Type | Method and Description |
---|---|
Mono<QueueProperties> |
createQueue(String queueName)
Creates a queue with the given name.
|
Mono<QueueProperties> |
createQueue(String queueName,
CreateQueueOptions queueOptions)
Creates a queue with the
CreateQueueOptions and given queue name. |
Mono<com.azure.core.http.rest.Response<QueueProperties>> |
createQueueWithResponse(String queueName,
CreateQueueOptions queueOptions)
Creates a queue and returns the created queue in addition to the HTTP response.
|
Mono<RuleProperties> |
createRule(String topicName,
String subscriptionName,
String ruleName)
Creates a rule under the given topic and subscription
|
Mono<RuleProperties> |
createRule(String topicName,
String subscriptionName,
String ruleName,
CreateRuleOptions ruleOptions)
Creates a rule with the
CreateRuleOptions . |
Mono<com.azure.core.http.rest.Response<RuleProperties>> |
createRuleWithResponse(String topicName,
String subscriptionName,
String ruleName,
CreateRuleOptions ruleOptions)
Creates a rule and returns the created rule in addition to the HTTP response.
|
Mono<SubscriptionProperties> |
createSubscription(String topicName,
String subscriptionName)
Creates a subscription with the given topic and subscription names.
|
Mono<SubscriptionProperties> |
createSubscription(String topicName,
String subscriptionName,
CreateSubscriptionOptions subscriptionOptions)
Creates a subscription with the
CreateSubscriptionOptions . |
Mono<com.azure.core.http.rest.Response<SubscriptionProperties>> |
createSubscriptionWithResponse(String topicName,
String subscriptionName,
CreateSubscriptionOptions subscriptionOptions)
Creates a subscription and returns the created subscription in addition to the HTTP response.
|
Mono<TopicProperties> |
createTopic(String topicName)
Creates a topic with the given name.
|
Mono<TopicProperties> |
createTopic(String topicName,
CreateTopicOptions topicOptions)
Creates a topic with the
CreateTopicOptions . |
Mono<com.azure.core.http.rest.Response<TopicProperties>> |
createTopicWithResponse(String topicName,
CreateTopicOptions topicOptions)
Creates a topic and returns the created topic in addition to the HTTP response.
|
Mono<Void> |
deleteQueue(String queueName)
Deletes a queue the matching
queueName . |
Mono<com.azure.core.http.rest.Response<Void>> |
deleteQueueWithResponse(String queueName)
Deletes a queue the matching
queueName and returns the HTTP response. |
Mono<Void> |
deleteRule(String topicName,
String subscriptionName,
String ruleName)
Deletes a rule the matching
ruleName . |
Mono<com.azure.core.http.rest.Response<Void>> |
deleteRuleWithResponse(String topicName,
String subscriptionName,
String ruleName)
Deletes a rule the matching
ruleName and returns the HTTP response. |
Mono<Void> |
deleteSubscription(String topicName,
String subscriptionName)
Deletes a subscription the matching
subscriptionName . |
Mono<com.azure.core.http.rest.Response<Void>> |
deleteSubscriptionWithResponse(String topicName,
String subscriptionName)
Deletes a subscription the matching
subscriptionName and returns the HTTP response. |
Mono<Void> |
deleteTopic(String topicName)
Deletes a topic the matching
topicName . |
Mono<com.azure.core.http.rest.Response<Void>> |
deleteTopicWithResponse(String topicName)
Deletes a topic the matching
topicName and returns the HTTP response. |
Mono<NamespaceProperties> |
getNamespaceProperties()
Gets information about the Service Bus namespace.
|
Mono<com.azure.core.http.rest.Response<NamespaceProperties>> |
getNamespacePropertiesWithResponse()
Gets information about the Service Bus namespace along with its HTTP response.
|
Mono<QueueProperties> |
getQueue(String queueName)
Gets information about the queue.
|
Mono<Boolean> |
getQueueExists(String queueName)
Gets whether or not a queue with
queueName exists in the Service Bus namespace. |
Mono<com.azure.core.http.rest.Response<Boolean>> |
getQueueExistsWithResponse(String queueName)
Gets whether or not a queue with
queueName exists in the Service Bus namespace. |
Mono<QueueRuntimeProperties> |
getQueueRuntimeProperties(String queueName)
Gets runtime properties about the queue.
|
Mono<com.azure.core.http.rest.Response<QueueRuntimeProperties>> |
getQueueRuntimePropertiesWithResponse(String queueName)
Gets runtime properties about the queue along with its HTTP response.
|
Mono<com.azure.core.http.rest.Response<QueueProperties>> |
getQueueWithResponse(String queueName)
Gets information about the queue along with its HTTP response.
|
Mono<RuleProperties> |
getRule(String topicName,
String subscriptionName,
String ruleName)
Gets a rule from the service namespace.
|
Mono<com.azure.core.http.rest.Response<RuleProperties>> |
getRuleWithResponse(String topicName,
String subscriptionName,
String ruleName)
Gets a rule from the service namespace.
|
Mono<SubscriptionProperties> |
getSubscription(String topicName,
String subscriptionName)
Gets information about the queue.
|
Mono<Boolean> |
getSubscriptionExists(String topicName,
String subscriptionName)
Gets whether or not a subscription within a topic exists.
|
Mono<com.azure.core.http.rest.Response<Boolean>> |
getSubscriptionExistsWithResponse(String topicName,
String subscriptionName)
Gets whether or not a subscription within a topic exists.
|
Mono<SubscriptionRuntimeProperties> |
getSubscriptionRuntimeProperties(String topicName,
String subscriptionName)
Gets runtime properties about the subscription.
|
Mono<com.azure.core.http.rest.Response<SubscriptionRuntimeProperties>> |
getSubscriptionRuntimePropertiesWithResponse(String topicName,
String subscriptionName)
Gets runtime properties about the subscription.
|
Mono<com.azure.core.http.rest.Response<SubscriptionProperties>> |
getSubscriptionWithResponse(String topicName,
String subscriptionName)
Gets information about the subscription along with its HTTP response.
|
Mono<TopicProperties> |
getTopic(String topicName)
Gets information about the topic.
|
Mono<Boolean> |
getTopicExists(String topicName)
Gets whether or not a topic with
topicName exists in the Service Bus namespace. |
Mono<com.azure.core.http.rest.Response<Boolean>> |
getTopicExistsWithResponse(String topicName)
Gets whether or not a topic with
topicName exists in the Service Bus namespace. |
Mono<TopicRuntimeProperties> |
getTopicRuntimeProperties(String topicName)
Gets runtime properties about the topic.
|
Mono<com.azure.core.http.rest.Response<TopicRuntimeProperties>> |
getTopicRuntimePropertiesWithResponse(String topicName)
Gets runtime properties about the topic with its HTTP response.
|
Mono<com.azure.core.http.rest.Response<TopicProperties>> |
getTopicWithResponse(String topicName)
Gets information about the topic along with its HTTP response.
|
com.azure.core.http.rest.PagedFlux<QueueProperties> |
listQueues()
Fetches all the queues in the Service Bus namespace.
|
com.azure.core.http.rest.PagedFlux<RuleProperties> |
listRules(String topicName,
String subscriptionName)
Fetches all the rules for a topic and subscription.
|
com.azure.core.http.rest.PagedFlux<SubscriptionProperties> |
listSubscriptions(String topicName)
Fetches all the subscriptions for a topic.
|
com.azure.core.http.rest.PagedFlux<TopicProperties> |
listTopics()
Fetches all the topics in the Service Bus namespace.
|
Mono<QueueProperties> |
updateQueue(QueueProperties queue)
Updates a queue with the given
QueueProperties . |
Mono<com.azure.core.http.rest.Response<QueueProperties>> |
updateQueueWithResponse(QueueProperties queue)
Updates a queue with the given
QueueProperties . |
Mono<RuleProperties> |
updateRule(String topicName,
String subscriptionName,
RuleProperties rule)
Updates a rule with the given
RuleProperties . |
Mono<com.azure.core.http.rest.Response<RuleProperties>> |
updateRuleWithResponse(String topicName,
String subscriptionName,
RuleProperties rule)
Updates a rule with the given
RuleProperties . |
Mono<SubscriptionProperties> |
updateSubscription(SubscriptionProperties subscription)
Updates a subscription with the given
SubscriptionProperties . |
Mono<com.azure.core.http.rest.Response<SubscriptionProperties>> |
updateSubscriptionWithResponse(SubscriptionProperties subscription)
Updates a subscription with the given
SubscriptionProperties . |
Mono<TopicProperties> |
updateTopic(TopicProperties topic)
Updates a topic with the given
TopicProperties . |
Mono<com.azure.core.http.rest.Response<TopicProperties>> |
updateTopicWithResponse(TopicProperties topic)
Updates a topic with the given
TopicProperties . |
public Mono<QueueProperties> createQueue(String queueName)
queueName
- Name of the queue to create.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the queue quota is exceeded, or an error
occurred processing the request.NullPointerException
- if queueName
is null.IllegalArgumentException
- if queueName
is an empty string.com.azure.core.exception.ResourceExistsException
- if a queue exists with the same queueName
.public Mono<QueueProperties> createQueue(String queueName, CreateQueueOptions queueOptions)
CreateQueueOptions
and given queue name.queueName
- Name of the queue to create.queueOptions
- Options about the queue to create.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the queue quota is exceeded, or an error
occurred processing the request.IllegalArgumentException
- if queueName
is an empty string.NullPointerException
- if queueName
or queueOptions
is null.com.azure.core.exception.ResourceExistsException
- if a queue exists with the same queueName
.public Mono<com.azure.core.http.rest.Response<QueueProperties>> createQueueWithResponse(String queueName, CreateQueueOptions queueOptions)
queueName
- Name of the queue to create.queueOptions
- Options about the queue to create.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the queue quota is exceeded, or an error
occurred processing the request.IllegalArgumentException
- if queueName
is an empty string.NullPointerException
- if queueName
or queueOptions
is null.com.azure.core.exception.ResourceExistsException
- if a queue exists with the same queueName
.public Mono<RuleProperties> createRule(String topicName, String subscriptionName, String ruleName)
topicName
- Name of the topic associated with rule.subscriptionName
- Name of the subscription associated with the rule.ruleName
- Name of the rule.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the quota is exceeded, or an error occurred
processing the request.IllegalArgumentException
- if topicName
or ruleName
are are empty strings.NullPointerException
- if topicName
or ruleName
are are null.com.azure.core.exception.ResourceExistsException
- if a rule exists with the same topic, subscription, and rule name.public Mono<RuleProperties> createRule(String topicName, String subscriptionName, String ruleName, CreateRuleOptions ruleOptions)
CreateRuleOptions
.topicName
- Name of the topic associated with rule.subscriptionName
- Name of the subscription associated with the rule.ruleName
- Name of the rule.ruleOptions
- Information about the rule to create.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the quota is exceeded, or an error occurred
processing the request.IllegalArgumentException
- if topicName
or ruleName
are are empty strings.NullPointerException
- if topicName
, ruleName
, or ruleOptions
are are null.com.azure.core.exception.ResourceExistsException
- if a rule exists with the same topic and rule name.public Mono<com.azure.core.http.rest.Response<RuleProperties>> createRuleWithResponse(String topicName, String subscriptionName, String ruleName, CreateRuleOptions ruleOptions)
topicName
- Name of the topic associated with rule.subscriptionName
- Name of the subscription associated with the rule.ruleName
- Name of the rule.ruleOptions
- Information about the rule to create.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the quota is exceeded, or an error occurred
processing the request.IllegalArgumentException
- if topicName
or ruleName
are are empty strings.NullPointerException
- if topicName
, ruleName
, or ruleOptions
are are null.com.azure.core.exception.ResourceExistsException
- if a rule exists with the same topic and rule name.public Mono<SubscriptionProperties> createSubscription(String topicName, String subscriptionName)
topicName
- Name of the topic associated with subscription.subscriptionName
- Name of the subscription.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the quota is exceeded, or an error occurred
processing the request.IllegalArgumentException
- if topicName
or subscriptionName
are are empty strings.NullPointerException
- if topicName
or subscriptionName
are are null.com.azure.core.exception.ResourceExistsException
- if a subscription exists with the same topic and subscription name.public Mono<SubscriptionProperties> createSubscription(String topicName, String subscriptionName, CreateSubscriptionOptions subscriptionOptions)
CreateSubscriptionOptions
.topicName
- Name of the topic associated with subscription.subscriptionName
- Name of the subscription.subscriptionOptions
- Information about the subscription to create.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the quota is exceeded, or an error occurred
processing the request.IllegalArgumentException
- if topicName
or subscriptionName
are are empty strings.NullPointerException
- if topicName
, subscriptionName
, or subscriptionOptions
are are null.com.azure.core.exception.ResourceExistsException
- if a subscription exists with the same topic and subscription name.public Mono<com.azure.core.http.rest.Response<SubscriptionProperties>> createSubscriptionWithResponse(String topicName, String subscriptionName, CreateSubscriptionOptions subscriptionOptions)
topicName
- Name of the topic associated with subscription.subscriptionName
- Name of the subscription.subscriptionOptions
- Information about the subscription to create.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the quota is exceeded, or an error occurred
processing the request.IllegalArgumentException
- if topicName
or subscriptionName
are are empty strings.NullPointerException
- if topicName
, subscriptionName
, or subscriptionOptions
are are null.com.azure.core.exception.ResourceExistsException
- if a subscription exists with the same topic and subscription name.public Mono<TopicProperties> createTopic(String topicName)
topicName
- Name of the topic to create.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the topic quota is exceeded, or an error
occurred processing the request.NullPointerException
- if topicName
is null.IllegalArgumentException
- if topicName
is an empty string.com.azure.core.exception.ResourceExistsException
- if a topic exists with the same topicName
.public Mono<TopicProperties> createTopic(String topicName, CreateTopicOptions topicOptions)
CreateTopicOptions
.topicName
- Name of the topic to create.topicOptions
- The options used to create the topic.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the topic quota is exceeded, or an error
occurred processing the request.IllegalArgumentException
- if topicName
is an empty string.NullPointerException
- if topicName
or topicOptions
is null.com.azure.core.exception.ResourceExistsException
- if a topic exists with the same topicName
.public Mono<com.azure.core.http.rest.Response<TopicProperties>> createTopicWithResponse(String topicName, CreateTopicOptions topicOptions)
topicName
- Name of the topic to create.topicOptions
- The options used to create the topic.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the topic quota is exceeded, or an error
occurred processing the request.IllegalArgumentException
- if topic.getName()
is null or an empty
string.NullPointerException
- if topicName
or topicOptions
is null.com.azure.core.exception.ResourceExistsException
- if a topic exists with the same topicName
.public Mono<Void> deleteQueue(String queueName)
queueName
.queueName
- Name of queue to delete.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.NullPointerException
- if queueName
is null.IllegalArgumentException
- if queueName
is an empty string.com.azure.core.exception.ResourceNotFoundException
- if the queueName
does not exist.public Mono<com.azure.core.http.rest.Response<Void>> deleteQueueWithResponse(String queueName)
queueName
and returns the HTTP response.queueName
- Name of queue to delete.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.NullPointerException
- if queueName
is null.IllegalArgumentException
- if queueName
is an empty string.com.azure.core.exception.ResourceNotFoundException
- if the queueName
does not exist.public Mono<Void> deleteRule(String topicName, String subscriptionName, String ruleName)
ruleName
.topicName
- Name of topic associated with rule to delete.subscriptionName
- Name of the subscription associated with the rule to delete.ruleName
- Name of rule to delete.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
or ruleName
is an empty string.NullPointerException
- if topicName
or ruleName
is null.com.azure.core.exception.ResourceNotFoundException
- if the ruleName
does not exist.public Mono<com.azure.core.http.rest.Response<Void>> deleteRuleWithResponse(String topicName, String subscriptionName, String ruleName)
ruleName
and returns the HTTP response.topicName
- Name of topic associated with rule to delete.subscriptionName
- Name of the subscription associated with the rule to delete.ruleName
- Name of rule to delete.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
, subscriptionName
, or ruleName
is an
empty string.NullPointerException
- if topicName
, subscriptionName
, or ruleName
is null.com.azure.core.exception.ResourceNotFoundException
- if the ruleName
does not exist.public Mono<Void> deleteSubscription(String topicName, String subscriptionName)
subscriptionName
.topicName
- Name of topic associated with subscription to delete.subscriptionName
- Name of subscription to delete.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
or subscriptionName
is an empty string.NullPointerException
- if topicName
or subscriptionName
is null.com.azure.core.exception.ResourceNotFoundException
- if the subscriptionName
does not exist.public Mono<com.azure.core.http.rest.Response<Void>> deleteSubscriptionWithResponse(String topicName, String subscriptionName)
subscriptionName
and returns the HTTP response.topicName
- Name of topic associated with subscription to delete.subscriptionName
- Name of subscription to delete.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
or subscriptionName
is an empty string.NullPointerException
- if topicName
or subscriptionName
is null.com.azure.core.exception.ResourceNotFoundException
- if the subscriptionName
does not exist.public Mono<Void> deleteTopic(String topicName)
topicName
.topicName
- Name of topic to delete.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
is an empty string.NullPointerException
- if topicName
is null.com.azure.core.exception.ResourceNotFoundException
- if the topicName
does not exist.public Mono<com.azure.core.http.rest.Response<Void>> deleteTopicWithResponse(String topicName)
topicName
and returns the HTTP response.topicName
- Name of topic to delete.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
is an empty string.NullPointerException
- if topicName
is null.com.azure.core.exception.ResourceNotFoundException
- if the topicName
does not exist.public Mono<QueueProperties> getQueue(String queueName)
queueName
- Name of queue to get information about.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if queueName
is an empty string.NullPointerException
- if queueName
is null.com.azure.core.exception.ResourceNotFoundException
- if the queueName
does not exist.public Mono<com.azure.core.http.rest.Response<QueueProperties>> getQueueWithResponse(String queueName)
queueName
- Name of queue to get information about.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if queueName
is an empty string.NullPointerException
- if queueName
is null.com.azure.core.exception.ResourceNotFoundException
- if the queueName
does not exist.public Mono<Boolean> getQueueExists(String queueName)
queueName
exists in the Service Bus namespace.queueName
- Name of the queue.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if queueName
is an empty string.NullPointerException
- if queueName
is null.public Mono<com.azure.core.http.rest.Response<Boolean>> getQueueExistsWithResponse(String queueName)
queueName
exists in the Service Bus namespace.queueName
- Name of the queue.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if queueName
is an empty string.NullPointerException
- if queueName
is null.public Mono<QueueRuntimeProperties> getQueueRuntimeProperties(String queueName)
queueName
- Name of queue to get information about.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if queueName
is an empty string.NullPointerException
- if queueName
is null.com.azure.core.exception.ResourceNotFoundException
- if the queueName
does not exist.public Mono<com.azure.core.http.rest.Response<QueueRuntimeProperties>> getQueueRuntimePropertiesWithResponse(String queueName)
queueName
- Name of queue to get information about.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if queueName
is an empty string.NullPointerException
- if queueName
is null.com.azure.core.exception.ResourceNotFoundException
- if the queueName
does not exist.public Mono<NamespaceProperties> getNamespaceProperties()
com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to the namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.public Mono<com.azure.core.http.rest.Response<NamespaceProperties>> getNamespacePropertiesWithResponse()
com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.public Mono<RuleProperties> getRule(String topicName, String subscriptionName, String ruleName)
topicName
- The name of the topic relative to service bus namespace.subscriptionName
- The subscription name the rule belongs to.ruleName
- The name of the rule to retrieve.public Mono<com.azure.core.http.rest.Response<RuleProperties>> getRuleWithResponse(String topicName, String subscriptionName, String ruleName)
topicName
- The name of the topic relative to service bus namespace.subscriptionName
- The subscription name the rule belongs to.ruleName
- The name of the rule to retrieve.public Mono<SubscriptionProperties> getSubscription(String topicName, String subscriptionName)
topicName
- Name of topic associated with subscription.subscriptionName
- Name of subscription to get information about.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
or subscriptionName
are empty strings.NullPointerException
- if topicName
or subscriptionName
are null.com.azure.core.exception.ResourceNotFoundException
- if the subscriptionName
does not exist in the topicName
.public Mono<com.azure.core.http.rest.Response<SubscriptionProperties>> getSubscriptionWithResponse(String topicName, String subscriptionName)
topicName
- Name of topic associated with subscription.subscriptionName
- Name of subscription to get information about.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
or subscriptionName
are empty strings.NullPointerException
- if topicName
or subscriptionName
are null.com.azure.core.exception.ResourceNotFoundException
- if the subscriptionName
does not exist.public Mono<Boolean> getSubscriptionExists(String topicName, String subscriptionName)
topicName
- Name of topic associated with subscription.subscriptionName
- Name of the subscription.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if subscriptionName
is an empty string.NullPointerException
- if subscriptionName
is null.public Mono<com.azure.core.http.rest.Response<Boolean>> getSubscriptionExistsWithResponse(String topicName, String subscriptionName)
topicName
- Name of topic associated with subscription.subscriptionName
- Name of the subscription.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if subscriptionName
is an empty string.NullPointerException
- if subscriptionName
is null.public Mono<SubscriptionRuntimeProperties> getSubscriptionRuntimeProperties(String topicName, String subscriptionName)
topicName
- Name of topic associated with subscription.subscriptionName
- Name of subscription to get information about.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
or subscriptionName
are empty strings.NullPointerException
- if topicName
or subscriptionName
are null.com.azure.core.exception.ResourceNotFoundException
- if the subscriptionName
does not exist.public Mono<com.azure.core.http.rest.Response<SubscriptionRuntimeProperties>> getSubscriptionRuntimePropertiesWithResponse(String topicName, String subscriptionName)
topicName
- Name of topic associated with subscription.subscriptionName
- Name of subscription to get information about.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if subscriptionName
is an empty string.NullPointerException
- if subscriptionName
is null.com.azure.core.exception.ResourceNotFoundException
- if the subscriptionName
does not exist.public Mono<TopicProperties> getTopic(String topicName)
topicName
- Name of topic to get information about.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
is an empty string.NullPointerException
- if topicName
is null.com.azure.core.exception.ResourceNotFoundException
- if the topicName
does not exist.public Mono<com.azure.core.http.rest.Response<TopicProperties>> getTopicWithResponse(String topicName)
topicName
- Name of topic to get information about.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
is an empty string.NullPointerException
- if topicName
is null.com.azure.core.exception.ResourceNotFoundException
- if the topicName
does not exist.public Mono<Boolean> getTopicExists(String topicName)
topicName
exists in the Service Bus namespace.topicName
- Name of the topic.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
is an empty string.NullPointerException
- if topicName
is null.public Mono<com.azure.core.http.rest.Response<Boolean>> getTopicExistsWithResponse(String topicName)
topicName
exists in the Service Bus namespace.topicName
- Name of the topic.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
is an empty string.NullPointerException
- if topicName
is null.public Mono<TopicRuntimeProperties> getTopicRuntimeProperties(String topicName)
topicName
- Name of topic to get information about.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
is an empty string.NullPointerException
- if topicName
is null.com.azure.core.exception.ResourceNotFoundException
- if the topicName
does not exist.public Mono<com.azure.core.http.rest.Response<TopicRuntimeProperties>> getTopicRuntimePropertiesWithResponse(String topicName)
topicName
- Name of topic to get information about.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If error occurred processing the request.IllegalArgumentException
- if topicName
is an empty string.NullPointerException
- if topicName
is null.com.azure.core.exception.ResourceNotFoundException
- if the topicName
does not exist.public com.azure.core.http.rest.PagedFlux<QueueProperties> listQueues()
queues
in the Service Bus namespace.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.public com.azure.core.http.rest.PagedFlux<RuleProperties> listRules(String topicName, String subscriptionName)
topicName
- The topic name under which all the rules need to be retrieved.subscriptionName
- The name of the subscription for which all rules need to be retrieved.rules
for the topicName
and subscriptionName
.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.NullPointerException
- if topicName
or subscriptionName
is null.IllegalArgumentException
- if topicName
or subscriptionName
is an empty string.public com.azure.core.http.rest.PagedFlux<SubscriptionProperties> listSubscriptions(String topicName)
topicName
- The topic name under which all the subscriptions need to be retrieved.subscriptions
for the topicName
.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.NullPointerException
- if topicName
is null.IllegalArgumentException
- if topicName
is an empty string.public com.azure.core.http.rest.PagedFlux<TopicProperties> listTopics()
topics
in the Service Bus namespace.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.public Mono<QueueProperties> updateQueue(QueueProperties queue)
QueueProperties
. The QueueProperties
must be fully populated as
all of the properties are replaced. If a property is not set the service default value is used.
The suggested flow is:
Get queue description.
There are a subset of properties that can be updated. More information can be found in the links below. They are:
queue
- Information about the queue to update. You must provide all the property values that are desired
on the updated entity. Any values not provided are set to the service default values.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the queue quota is exceeded, or an error
occurred processing the request.NullPointerException
- if queue
is null.public Mono<com.azure.core.http.rest.Response<QueueProperties>> updateQueueWithResponse(QueueProperties queue)
QueueProperties
. The QueueProperties
must be fully populated as
all of the properties are replaced. If a property is not set the service default value is used.
The suggested flow is:
Get queue description.
There are a subset of properties that can be updated. More information can be found in the links below. They are:
queue
- Information about the queue to update. You must provide all the property values that are desired
on the updated entity. Any values not provided are set to the service default values.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the queue quota is exceeded, or an error
occurred processing the request.NullPointerException
- if queue
is null.public Mono<RuleProperties> updateRule(String topicName, String subscriptionName, RuleProperties rule)
RuleProperties
. The RuleProperties
must be fully populated as all
of the properties are replaced. If a property is not set the service default value is used.
The suggested flow is:
Get rule description.
topicName
- The topic name under which the rule is updated.subscriptionName
- The name of the subscription for which the rule is updated.rule
- Information about the rule to update. You must provide all the property values that are desired
on the updated entity. Any values not provided are set to the service default values.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the rule quota is exceeded, or an error
occurred processing the request.IllegalArgumentException
- if RuleProperties.getName()
is null or an empty string.NullPointerException
- if rule
is null.public Mono<com.azure.core.http.rest.Response<RuleProperties>> updateRuleWithResponse(String topicName, String subscriptionName, RuleProperties rule)
RuleProperties
. The RuleProperties
must be fully populated as all
of the properties are replaced. If a property is not set the service default value is used.
The suggested flow is:
Get rule description.
topicName
- The topic name under which the rule is updated.subscriptionName
- The name of the subscription for which the rule is updated.rule
- Information about the rule to update. You must provide all the property values that are desired
on the updated entity. Any values not provided are set to the service default values.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the rule quota is exceeded, or an error
occurred processing the request.IllegalArgumentException
- if RuleProperties.getName()
is null or an empty string.NullPointerException
- if rule
is null.public Mono<SubscriptionProperties> updateSubscription(SubscriptionProperties subscription)
SubscriptionProperties
. The SubscriptionProperties
must be
fully populated as all of the properties are replaced. If a property is not set the service default value is
used.
The suggested flow is:
Get subscription description.
There are a subset of properties that can be updated. More information can be found in the links below. They are:
subscription
- Information about the subscription to update. You must provide all the property values
that are desired on the updated entity. Any values not provided are set to the service default values.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the subscription quota is exceeded, or an
error occurred processing the request.IllegalArgumentException
- if SubscriptionProperties.getTopicName()
or SubscriptionProperties.getSubscriptionName()
is null or an empty string.NullPointerException
- if subscription
is null.public Mono<com.azure.core.http.rest.Response<SubscriptionProperties>> updateSubscriptionWithResponse(SubscriptionProperties subscription)
SubscriptionProperties
. The SubscriptionProperties
must be
fully populated as all of the properties are replaced. If a property is not set the service default value is
used.
The suggested flow is:
Get subscription description.
There are a subset of properties that can be updated. More information can be found in the links below. They are:
subscription
- Information about the subscription to update. You must provide all the property values
that are desired on the updated entity. Any values not provided are set to the service default values.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the subscription quota is exceeded, or an
error occurred processing the request.IllegalArgumentException
- if SubscriptionProperties.getTopicName()
or SubscriptionProperties.getSubscriptionName()
is null or an empty string.NullPointerException
- if subscription
is null.public Mono<TopicProperties> updateTopic(TopicProperties topic)
TopicProperties
. The TopicProperties
must be fully populated as
all of the properties are replaced. If a property is not set the service default value is used.
The suggested flow is:
Get topic description.
There are a subset of properties that can be updated. More information can be found in the links below. They are:
topic
- Information about the topic to update. You must provide all the property values that are desired
on the updated entity. Any values not provided are set to the service default values.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the topic quota is exceeded, or an error
occurred processing the request.IllegalArgumentException
- if topic.getName()
is null or an empty
string.NullPointerException
- if topic
is null.public Mono<com.azure.core.http.rest.Response<TopicProperties>> updateTopicWithResponse(TopicProperties topic)
TopicProperties
. The TopicProperties
must be fully populated as
all of the properties are replaced. If a property is not set the service default value is used.
The suggested flow is:
Get topic description.
There are a subset of properties that can be updated. More information can be found in the links below. They are:
topic
- Information about the topic to update. You must provide all the property values that are desired
on the updated entity. Any values not provided are set to the service default values.com.azure.core.exception.ClientAuthenticationException
- if the client's credentials do not have access to modify the
namespace.com.azure.core.exception.HttpResponseException
- If the request body was invalid, the topic quota is exceeded, or an error
occurred processing the request.IllegalArgumentException
- if topic.getName()
is null or an empty
string.NullPointerException
- if topic
is null.Copyright © 2021 Microsoft Corporation. All rights reserved.