ServiceBusAdministrationAsyncClient Classe

Paquet:

com.azure.messaging.servicebus.administration

Artefact Maven:

com.azure:azure-messaging-servicebus:7.17.0

• java.lang.Object
• • com.azure.messaging.servicebus.administration.ServiceBusAdministrationAsyncClient

public final class ServiceBusAdministrationAsyncClient

Client asynchrone pour la gestion d’un espace de noms Service Bus. Instancié via ServiceBusAdministrationClientBuilder.

Exemple : Créer le client asynchrone

L’exemple de code suivant illustre la création du client d’administration asynchrone. Les informations d’identification utilisées dans l’exemple suivant sont pour l’authentification DefaultAzureCredential . Il convient à la plupart des scénarios, y compris aux environnements de développement et de production locaux. En outre, nous vous recommandons d’utiliser l’identité managée pour l’authentification dans les environnements de production. Vous trouverez plus d’informations sur les différentes méthodes d’authentification et leurs types d’informations d’identification correspondants dans la documentation Azure Identity.

// DefaultAzureCredential creates a credential based on the environment it is executed in.
 TokenCredential credential = new DefaultAzureCredentialBuilder().build();

 // 'fullyQualifiedNamespace' will look similar to "{your-namespace}.servicebus.windows.net"
 ServiceBusAdministrationAsyncClient client = new ServiceBusAdministrationClientBuilder()
     .credential(fullyQualifiedNamespace, new DefaultAzureCredentialBuilder().build())
     .buildAsyncClient();

Exemple : Créer une file d’attente

L’exemple suivant crée une file d’attente avec des valeurs par défaut. Les valeurs par défaut sont répertoriées dans CreateQueueOptions().

// `.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);
     });

Exemple : Modifier un abonnement existant

L’exemple de code suivant illustre la mise à jour d’un abonnement existant. Les utilisateurs doivent extraire les propriétés de l’abonnement, modifier les propriétés, puis passer l’objet à la méthode de mise à jour.

// 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);
         });

Exemple : Répertorier toutes les files d’attente

L’exemple de code ci-dessous répertorie toutes les files d’attente dans l’espace de noms Service Bus.

// `.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);
     });

Exemple : Supprimer la file d’attente

L’exemple de code ci-dessous illustre la suppression d’une file d’attente existante.

// `.subscribe()` is a non-blocking call. It'll move onto the next
 // instruction after setting up the `consumer`, `errorConsumer`, `completeConsumer` callbacks.
 asyncClient.deleteQueue("my-existing-queue").subscribe(unused -> {
 }, error -> {
     System.err.println("Error deleting queue: " + error);
 }, () -> {
     System.out.println("Deleted queue.");
 });

Résumé de la méthode

Modificateur et type	Méthode et description
Mono<QueueProperties>	createQueue(String queueName) Crée une file d’attente avec le nom donné.
Mono<QueueProperties>	createQueue(String queueName, CreateQueueOptions queueOptions) Crée une file d’attente avec le nom de file d’attente CreateQueueOptions et donné.
Mono<Response<QueueProperties>>	createQueueWithResponse(String queueName, CreateQueueOptions queueOptions) Crée une file d’attente et retourne la file d’attente créée en plus de la réponse HTTP.
Mono<RuleProperties>	createRule(String topicName, String subscriptionName, String ruleName) Crée une règle sous la rubrique et l’abonnement donnés
Mono<RuleProperties>	createRule(String topicName, String subscriptionName, String ruleName, CreateRuleOptions ruleOptions) Crée une règle avec .CreateRuleOptions
Mono<Response<RuleProperties>>	createRuleWithResponse(String topicName, String subscriptionName, String ruleName, CreateRuleOptions ruleOptions) Crée une règle et retourne la règle créée en plus de la réponse HTTP.
Mono<SubscriptionProperties>	createSubscription(String topicName, String subscriptionName) Crée un abonnement avec les noms de rubrique et d’abonnement donnés.
Mono<SubscriptionProperties>	createSubscription(String topicName, String subscriptionName, CreateSubscriptionOptions subscriptionOptions) Crée un abonnement avec .CreateSubscriptionOptions
Mono<SubscriptionProperties>	createSubscription(String topicName, String subscriptionName, String ruleName, CreateSubscriptionOptions subscriptionOptions, CreateRuleOptions ruleOptions) Crée un abonnement avec une règle par défaut à l’aide de CreateSubscriptionOptions et CreateRuleOptions.
Mono<Response<SubscriptionProperties>>	createSubscriptionWithResponse(String topicName, String subscriptionName, CreateSubscriptionOptions subscriptionOptions) Crée un abonnement et retourne l’abonnement créé en plus de la réponse HTTP.
Mono<Response<SubscriptionProperties>>	createSubscriptionWithResponse(String topicName, String subscriptionName, String ruleName, CreateSubscriptionOptions subscriptionOptions, CreateRuleOptions ruleOptions) Crée un abonnement avec la règle par défaut et retourne l’abonnement créé en plus de la réponse HTTP.
Mono<TopicProperties>	createTopic(String topicName) Crée une rubrique portant le nom donné.
Mono<TopicProperties>	createTopic(String topicName, CreateTopicOptions topicOptions) Crée une rubrique avec .CreateTopicOptions
Mono<Response<TopicProperties>>	createTopicWithResponse(String topicName, CreateTopicOptions topicOptions) Crée une rubrique et retourne la rubrique créée en plus de la réponse HTTP.
Mono<Void>	deleteQueue(String queueName) Supprime une file d’attente correspondant à queueName.
Mono<Response<Void>>	deleteQueueWithResponse(String queueName) Supprime une file d’attente correspondant queueName et retourne la réponse HTTP.
Mono<Void>	deleteRule(String topicName, String subscriptionName, String ruleName) Supprime une règle correspondant ruleNameà .
Mono<Response<Void>>	deleteRuleWithResponse(String topicName, String subscriptionName, String ruleName) Supprime une règle correspondant ruleName et retourne la réponse HTTP.
Mono<Void>	deleteSubscription(String topicName, String subscriptionName) Supprime un abonnement correspondant subscriptionNameà .
Mono<Response<Void>>	deleteSubscriptionWithResponse(String topicName, String subscriptionName) Supprime un abonnement correspondant subscriptionName et retourne la réponse HTTP.
Mono<Void>	deleteTopic(String topicName) Supprime une rubrique correspondant à topicName.
Mono<Response<Void>>	deleteTopicWithResponse(String topicName) Supprime une rubrique correspondant topicName et retourne la réponse HTTP.
Mono<NamespaceProperties>	getNamespaceProperties() Obtient des informations sur l’espace de noms Service Bus.
Mono<Response<NamespaceProperties>>	getNamespacePropertiesWithResponse() Obtient des informations sur l’espace de noms Service Bus ainsi que sa réponse HTTP.
Mono<QueueProperties>	getQueue(String queueName) Obtient des informations sur la file d’attente.
Mono<Boolean>	getQueueExists(String queueName) Obtient si une file d’attente avec queueName existe ou non dans l’espace de noms Service Bus.
Mono<Response<Boolean>>	getQueueExistsWithResponse(String queueName) Obtient si une file d’attente avec queueName existe ou non dans l’espace de noms Service Bus.
Mono<QueueRuntimeProperties>	getQueueRuntimeProperties(String queueName) Obtient les propriétés du runtime sur la file d’attente.
Mono<Response<QueueRuntimeProperties>>	getQueueRuntimePropertiesWithResponse(String queueName) Obtient les propriétés d’exécution de la file d’attente ainsi que sa réponse HTTP.
Mono<Response<QueueProperties>>	getQueueWithResponse(String queueName) Obtient des informations sur la file d’attente ainsi que sa réponse HTTP.
Mono<RuleProperties>	getRule(String topicName, String subscriptionName, String ruleName) Obtient une règle à partir de l’espace de noms de service.
Mono<Response<RuleProperties>>	getRuleWithResponse(String topicName, String subscriptionName, String ruleName) Obtient une règle à partir de l’espace de noms de service.
Mono<SubscriptionProperties>	getSubscription(String topicName, String subscriptionName) Obtient des informations sur la file d’attente.
Mono<Boolean>	getSubscriptionExists(String topicName, String subscriptionName) Obtient si un abonnement dans une rubrique existe ou non.
Mono<Response<Boolean>>	getSubscriptionExistsWithResponse(String topicName, String subscriptionName) Obtient si un abonnement dans une rubrique existe ou non.
Mono<SubscriptionRuntimeProperties>	getSubscriptionRuntimeProperties(String topicName, String subscriptionName) Obtient les propriétés d’exécution relatives à l’abonnement.
Mono<Response<SubscriptionRuntimeProperties>>	getSubscriptionRuntimePropertiesWithResponse(String topicName, String subscriptionName) Obtient les propriétés d’exécution relatives à l’abonnement.
Mono<Response<SubscriptionProperties>>	getSubscriptionWithResponse(String topicName, String subscriptionName) Obtient des informations sur l’abonnement ainsi que sa réponse HTTP.
Mono<TopicProperties>	getTopic(String topicName) Obtient des informations sur la rubrique.
Mono<Boolean>	getTopicExists(String topicName) Obtient si une rubrique avec topicName existe ou non dans l’espace de noms Service Bus.
Mono<Response<Boolean>>	getTopicExistsWithResponse(String topicName) Obtient si une rubrique avec topicName existe ou non dans l’espace de noms Service Bus.
Mono<TopicRuntimeProperties>	getTopicRuntimeProperties(String topicName) Obtient les propriétés d’exécution relatives à la rubrique .
Mono<Response<TopicRuntimeProperties>>	getTopicRuntimePropertiesWithResponse(String topicName) Obtient les propriétés d’exécution de la rubrique avec sa réponse HTTP.
Mono<Response<TopicProperties>>	getTopicWithResponse(String topicName) Obtient des informations sur la rubrique ainsi que sa réponse HTTP.
PagedFlux<QueueProperties>	listQueues() Extrait toutes les files d’attente dans l’espace de noms Service Bus.
PagedFlux<RuleProperties>	listRules(String topicName, String subscriptionName) Extrait toutes les règles d’une rubrique et d’un abonnement.
PagedFlux<SubscriptionProperties>	listSubscriptions(String topicName) Extrait tous les abonnements d’une rubrique.
PagedFlux<TopicProperties>	listTopics() Extrait toutes les rubriques de l’espace de noms Service Bus.
Mono<QueueProperties>	updateQueue(QueueProperties queue) Mises à jour une file d’attente avec le donné QueueProperties.
Mono<Response<QueueProperties>>	updateQueueWithResponse(QueueProperties queue) Mises à jour une file d’attente avec le donné QueueProperties.
Mono<RuleProperties>	updateRule(String topicName, String subscriptionName, RuleProperties rule) Mises à jour une règle avec le donné RuleProperties.
Mono<Response<RuleProperties>>	updateRuleWithResponse(String topicName, String subscriptionName, RuleProperties rule) Mises à jour une règle avec le donné RuleProperties.
Mono<SubscriptionProperties>	updateSubscription(SubscriptionProperties subscription) Mises à jour un abonnement avec le donné SubscriptionProperties.
Mono<Response<SubscriptionProperties>>	updateSubscriptionWithResponse(SubscriptionProperties subscription) Mises à jour un abonnement avec le donné SubscriptionProperties.
Mono<TopicProperties>	updateTopic(TopicProperties topic) Mises à jour une rubrique avec le donné TopicProperties.
Mono<Response<TopicProperties>>	updateTopicWithResponse(TopicProperties topic) Mises à jour une rubrique avec le donné TopicProperties.

Méthodes héritées de java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Détails de la méthode

createQueue

public Mono createQueue(String queueName)

Crée une file d’attente avec le nom donné.

Parameters:

queueName - Nom de la file d’attente à créer.

Returns:

Mono qui se termine avec des informations sur la file d’attente créée.

createQueue

public Mono createQueue(String queueName, CreateQueueOptions queueOptions)

Crée une file d’attente avec le nom de file d’attente CreateQueueOptions et donné.

Parameters:

queueName - Nom de la file d’attente à créer.

queueOptions - Options relatives à la file d’attente à créer.

Returns:

Mono qui se termine avec des informations sur la file d’attente créée.

createQueueWithResponse

public Mono<>> createQueueWithResponse(String queueName, CreateQueueOptions queueOptions)

Crée une file d’attente et retourne la file d’attente créée en plus de la réponse HTTP.

Parameters:

queueName - Nom de la file d’attente à créer.

queueOptions - Options relatives à la file d’attente à créer.

Returns:

Mono qui retourne la file d’attente créée en plus de la réponse HTTP.

createRule

public Mono createRule(String topicName, String subscriptionName, String ruleName)

Crée une règle sous la rubrique et l’abonnement donnés

Parameters:

topicName - Nom de la rubrique associée à la règle.

subscriptionName - Nom de l’abonnement associé à la règle.

ruleName - Nom de la règle.

Returns:

Mono qui se termine avec des informations sur la règle créée.

createRule

public Mono createRule(String topicName, String subscriptionName, String ruleName, CreateRuleOptions ruleOptions)

Crée une règle avec .CreateRuleOptions

Parameters:

topicName - Nom de la rubrique associée à la règle.

subscriptionName - Nom de l’abonnement associé à la règle.

ruleName - Nom de la règle.

ruleOptions - Informations sur la règle à créer.

Returns:

Mono qui se termine avec des informations sur la règle créée.

createRuleWithResponse

public Mono<>> createRuleWithResponse(String topicName, String subscriptionName, String ruleName, CreateRuleOptions ruleOptions)

Crée une règle et retourne la règle créée en plus de la réponse HTTP.

Parameters:

topicName - Nom de la rubrique associée à la règle.

subscriptionName - Nom de l’abonnement associé à la règle.

ruleName - Nom de la règle.

ruleOptions - Informations sur la règle à créer.

Returns:

Mono qui retourne la règle créée en plus de la réponse HTTP.

createSubscription

public Mono createSubscription(String topicName, String subscriptionName)

Crée un abonnement avec les noms de rubrique et d’abonnement donnés.

Parameters:

topicName - Nom de la rubrique associée à l’abonnement.

subscriptionName - Nom de l'abonnement.

Returns:

Mono qui se termine avec des informations sur l’abonnement créé.

createSubscription

public Mono createSubscription(String topicName, String subscriptionName, CreateSubscriptionOptions subscriptionOptions)

Crée un abonnement avec .CreateSubscriptionOptions

Parameters:

topicName - Nom de la rubrique associée à l’abonnement.

subscriptionName - Nom de l'abonnement.

subscriptionOptions - Informations sur l’abonnement à créer.

Returns:

Mono qui se termine avec des informations sur l’abonnement créé.

createSubscription

public Mono createSubscription(String topicName, String subscriptionName, String ruleName, CreateSubscriptionOptions subscriptionOptions, CreateRuleOptions ruleOptions)

Crée un abonnement avec une règle par défaut à l’aide de CreateSubscriptionOptions et CreateRuleOptions.

Parameters:

topicName - Nom de la rubrique associée à l’abonnement.

subscriptionName - Nom de l'abonnement.

ruleName - Nom de la règle par défaut avec laquelle l’abonnement doit être créé.

subscriptionOptions - Objet CreateSubscriptionOptions décrivant l’abonnement à créer.

ruleOptions - Objet CreateRuleOptions décrivant la règle par défaut. Si la valeur est null, le filtre direct est créé.

Returns:

Mono qui se termine avec des informations sur l’abonnement créé.

createSubscriptionWithResponse

public Mono<>> createSubscriptionWithResponse(String topicName, String subscriptionName, CreateSubscriptionOptions subscriptionOptions)

Crée un abonnement et retourne l’abonnement créé en plus de la réponse HTTP.

Parameters:

topicName - Nom de la rubrique associée à l’abonnement.

subscriptionName - Nom de l'abonnement.

subscriptionOptions - Informations sur l’abonnement à créer.

Returns:

Mono qui retourne l’abonnement créé en plus de la réponse HTTP.

createSubscriptionWithResponse

public Mono<>> createSubscriptionWithResponse(String topicName, String subscriptionName, String ruleName, CreateSubscriptionOptions subscriptionOptions, CreateRuleOptions ruleOptions)

Crée un abonnement avec la règle par défaut et retourne l’abonnement créé en plus de la réponse HTTP.

Parameters:

topicName - Nom de la rubrique associée à l’abonnement.

subscriptionName - Nom de l'abonnement.

ruleName - Nom de la règle par défaut avec laquelle l’abonnement doit être créé.

subscriptionOptions - Objet CreateSubscriptionOptions décrivant l’abonnement à créer.

ruleOptions - Objet CreateRuleOptions décrivant la règle par défaut. Si la valeur est null, le filtre direct est créé.

Returns:

Mono qui retourne l’abonnement créé en plus de la réponse HTTP.

createTopic

public Mono createTopic(String topicName)

Crée une rubrique portant le nom donné.

Parameters:

topicName - Nom de la rubrique à créer.

Returns:

Mono qui se termine avec des informations sur la rubrique créée.

createTopic

public Mono createTopic(String topicName, CreateTopicOptions topicOptions)

Crée une rubrique avec .CreateTopicOptions

Parameters:

topicName - Nom de la rubrique à créer.

topicOptions - Options utilisées pour créer la rubrique.

Returns:

Mono qui se termine avec des informations sur la rubrique créée.

createTopicWithResponse

public Mono<>> createTopicWithResponse(String topicName, CreateTopicOptions topicOptions)

Crée une rubrique et retourne la rubrique créée en plus de la réponse HTTP.

Parameters:

topicName - Nom de la rubrique à créer.

topicOptions - Options utilisées pour créer la rubrique.

Returns:

Mono qui retourne la rubrique créée en plus de la réponse HTTP.

deleteQueue

public Mono deleteQueue(String queueName)

Supprime une file d’attente correspondant à queueName.

Parameters:

queueName - Nom de la file d’attente à supprimer.

Returns:

Mono qui se termine lorsque la file d’attente est supprimée.

deleteQueueWithResponse

public Mono<>> deleteQueueWithResponse(String queueName)

Supprime une file d’attente correspondant queueName et retourne la réponse HTTP.

Parameters:

queueName - Nom de la file d’attente à supprimer.

Returns:

Mono qui se termine lorsque la file d’attente est supprimée et retourne la réponse HTTP.

deleteRule

public Mono deleteRule(String topicName, String subscriptionName, String ruleName)

Supprime une règle correspondant ruleNameà .

Parameters:

topicName - Nom de la rubrique associée à la règle à supprimer.

subscriptionName - Nom de l’abonnement associé à la règle à supprimer.

ruleName - Nom de la règle à supprimer.

Returns:

Mono qui se termine lorsque la règle est supprimée.

deleteRuleWithResponse

public Mono<>> deleteRuleWithResponse(String topicName, String subscriptionName, String ruleName)

Supprime une règle correspondant ruleName et retourne la réponse HTTP.

Parameters:

topicName - Nom de la rubrique associée à la règle à supprimer.

subscriptionName - Nom de l’abonnement associé à la règle à supprimer.

ruleName - Nom de la règle à supprimer.

Returns:

Mono qui se termine lorsque la règle est supprimée et retourne la réponse HTTP.

deleteSubscription

public Mono deleteSubscription(String topicName, String subscriptionName)

Supprime un abonnement correspondant subscriptionNameà .

Parameters:

topicName - Nom de la rubrique associée à l’abonnement à supprimer.

subscriptionName - Nom de l’abonnement à supprimer.

Returns:

Mono qui se termine lorsque l’abonnement est supprimé.

deleteSubscriptionWithResponse

public Mono<>> deleteSubscriptionWithResponse(String topicName, String subscriptionName)

Supprime un abonnement correspondant subscriptionName et retourne la réponse HTTP.

Parameters:

topicName - Nom de la rubrique associée à l’abonnement à supprimer.

subscriptionName - Nom de l’abonnement à supprimer.

Returns:

Mono qui se termine lorsque l’abonnement est supprimé et retourne la réponse HTTP.

deleteTopic

public Mono deleteTopic(String topicName)

Supprime une rubrique correspondant à topicName.

Parameters:

topicName - Nom de la rubrique à supprimer.

Returns:

Mono qui se termine lorsque la rubrique est supprimée.

deleteTopicWithResponse

public Mono<>> deleteTopicWithResponse(String topicName)

Supprime une rubrique correspondant topicName et retourne la réponse HTTP.

Parameters:

topicName - Nom de la rubrique à supprimer.

Returns:

Mono qui se termine lorsque la rubrique est supprimée et retourne la réponse HTTP.

getNamespaceProperties

public Mono getNamespaceProperties()

Obtient des informations sur l’espace de noms Service Bus.

Returns:

Mono qui se termine avec des informations sur l’espace de noms Service Bus.

getNamespacePropertiesWithResponse

public Mono<>> getNamespacePropertiesWithResponse()

Obtient des informations sur l’espace de noms Service Bus ainsi que sa réponse HTTP.

Returns:

Mono qui se termine avec des informations sur l’espace de noms et la réponse HTTP associée.

getQueue

public Mono getQueue(String queueName)

Obtient des informations sur la file d’attente.

Parameters:

queueName - Nom de la file d’attente pour obtenir des informations.

Returns:

Mono qui se termine avec des informations sur la file d’attente.

getQueueExists

public Mono getQueueExists(String queueName)

Obtient si une file d’attente avec queueName existe ou non dans l’espace de noms Service Bus.

Parameters:

queueName - Nom de la file d’attente.

Returns:

Mono qui se termine indiquant si la file d’attente existe.

getQueueExistsWithResponse

public Mono<>> getQueueExistsWithResponse(String queueName)

Obtient si une file d’attente avec queueName existe ou non dans l’espace de noms Service Bus.

Parameters:

queueName - Nom de la file d’attente.

Returns:

Mono qui se termine indiquant si la file d’attente existe ou non avec sa réponse HTTP.

getQueueRuntimeProperties

public Mono getQueueRuntimeProperties(String queueName)

Obtient les propriétés du runtime sur la file d’attente.

Parameters:

queueName - Nom de la file d’attente pour obtenir des informations.

Returns:

Mono qui se termine avec des propriétés d’exécution sur la file d’attente.

getQueueRuntimePropertiesWithResponse

public Mono<>> getQueueRuntimePropertiesWithResponse(String queueName)

Obtient les propriétés d’exécution de la file d’attente ainsi que sa réponse HTTP.

Parameters:

queueName - Nom de la file d’attente pour obtenir des informations.

Returns:

Mono qui se termine avec des propriétés d’exécution sur la file d’attente et la réponse HTTP associée.

getQueueWithResponse

public Mono<>> getQueueWithResponse(String queueName)

Obtient des informations sur la file d’attente ainsi que sa réponse HTTP.

Parameters:

queueName - Nom de la file d’attente pour obtenir des informations.

Returns:

Mono qui se termine avec des informations sur la file d’attente et la réponse HTTP associée.

getRule

public Mono getRule(String topicName, String subscriptionName, String ruleName)

Obtient une règle à partir de l’espace de noms de service. Seuls les types de données suivants sont désérialisés dans filtres et paramètres d’action : string, int, long, boolean, double et OffsetDateTime. D’autres types de données retournent sa valeur de chaîne.

Parameters:

topicName - Nom de la rubrique relative à l’espace de noms Service Bus.

subscriptionName - Nom de l’abonnement auquel appartient la règle.

ruleName - Nom de la règle à récupérer.

Returns:

Règle associée.

getRuleWithResponse

public Mono<>> getRuleWithResponse(String topicName, String subscriptionName, String ruleName)

Obtient une règle à partir de l’espace de noms de service. Seuls les types de données suivants sont désérialisés dans filtres et paramètres d’action : string, int, long, bool, double et OffsetDateTime. D’autres types de données retournent sa valeur de chaîne.

Parameters:

topicName - Nom de la rubrique relative à l’espace de noms Service Bus.

subscriptionName - Nom de l’abonnement auquel appartient la règle.

ruleName - Nom de la règle à récupérer.

Returns:

Règle associée à la réponse HTTP correspondante.

getSubscription

public Mono getSubscription(String topicName, String subscriptionName)

Obtient des informations sur la file d’attente.

Parameters:

topicName - Nom de la rubrique associée à l’abonnement.

subscriptionName - Nom de l’abonnement sur lequel obtenir des informations.

Returns:

Mono qui se termine avec des informations sur l’abonnement.

getSubscriptionExists

public Mono getSubscriptionExists(String topicName, String subscriptionName)

Obtient si un abonnement dans une rubrique existe ou non.

Parameters:

topicName - Nom de la rubrique associée à l’abonnement.

subscriptionName - Nom de l'abonnement.

Returns:

Mono qui se termine indiquant si l’abonnement existe ou non.

getSubscriptionExistsWithResponse

public Mono<>> getSubscriptionExistsWithResponse(String topicName, String subscriptionName)

Obtient si un abonnement dans une rubrique existe ou non.

Parameters:

topicName - Nom de la rubrique associée à l’abonnement.

subscriptionName - Nom de l'abonnement.

Returns:

Mono qui se termine indiquant si l’abonnement existe avec sa réponse HTTP.

getSubscriptionRuntimeProperties

public Mono getSubscriptionRuntimeProperties(String topicName, String subscriptionName)

Obtient les propriétés d’exécution relatives à l’abonnement.

Parameters:

topicName - Nom de la rubrique associée à l’abonnement.

subscriptionName - Nom de l’abonnement sur lequel obtenir des informations.

Returns:

Mono qui se termine avec les propriétés d’exécution de l’abonnement.

getSubscriptionRuntimePropertiesWithResponse

public Mono<>> getSubscriptionRuntimePropertiesWithResponse(String topicName, String subscriptionName)

Obtient les propriétés d’exécution relatives à l’abonnement.

Parameters:

topicName - Nom de la rubrique associée à l’abonnement.

subscriptionName - Nom de l’abonnement sur lequel obtenir des informations.

Returns:

Mono qui se termine avec les propriétés d’exécution de l’abonnement.

getSubscriptionWithResponse

public Mono<>> getSubscriptionWithResponse(String topicName, String subscriptionName)

Obtient des informations sur l’abonnement ainsi que sa réponse HTTP.

Parameters:

topicName - Nom de la rubrique associée à l’abonnement.

subscriptionName - Nom de l’abonnement sur lequel obtenir des informations.

Returns:

Mono qui se termine avec des informations sur l’abonnement et la réponse HTTP associée.

getTopic

public Mono getTopic(String topicName)

Obtient des informations sur la rubrique.

Parameters:

topicName - Nom de la rubrique sur qui obtenir des informations.

Returns:

Mono qui se termine avec des informations sur la rubrique.

getTopicExists

public Mono getTopicExists(String topicName)

Obtient si une rubrique avec topicName existe ou non dans l’espace de noms Service Bus.

Parameters:

topicName - Nom de la rubrique.

Returns:

Mono qui se termine indiquant si la rubrique existe ou non.

getTopicExistsWithResponse

public Mono<>> getTopicExistsWithResponse(String topicName)

Obtient si une rubrique avec topicName existe ou non dans l’espace de noms Service Bus.

Parameters:

topicName - Nom de la rubrique.

Returns:

Mono qui se termine indiquant si la rubrique existe avec sa réponse HTTP.

getTopicRuntimeProperties

public Mono getTopicRuntimeProperties(String topicName)

Obtient les propriétés d’exécution relatives à la rubrique .

Parameters:

topicName - Nom de la rubrique sur qui obtenir des informations.

Returns:

Mono qui se termine avec les propriétés d’exécution de la rubrique.

getTopicRuntimePropertiesWithResponse

public Mono<>> getTopicRuntimePropertiesWithResponse(String topicName)

Obtient les propriétés d’exécution de la rubrique avec sa réponse HTTP.

Parameters:

topicName - Nom de la rubrique sur qui obtenir des informations.

Returns:

Mono qui se termine avec des propriétés d’exécution sur la rubrique et la réponse HTTP associée.

getTopicWithResponse

public Mono<>> getTopicWithResponse(String topicName)

Obtient des informations sur la rubrique ainsi que sa réponse HTTP.

Parameters:

topicName - Nom de la rubrique sur qui obtenir des informations.

Returns:

Mono qui se termine avec des informations sur la rubrique et la réponse HTTP associée.

listQueues

public PagedFlux listQueues()

Extrait toutes les files d’attente dans l’espace de noms Service Bus.

Returns:

Flux de dans l’espace de QueueProperties noms Service Bus.

listRules

public PagedFlux listRules(String topicName, String subscriptionName)

Extrait toutes les règles d’une rubrique et d’un abonnement.

Parameters:

topicName - Nom de la rubrique sous laquelle toutes les règles doivent être récupérées.

subscriptionName - Nom de l’abonnement pour lequel toutes les règles doivent être récupérées.

Returns:

Flux de RuleProperties pour et topicNamesubscriptionName.

listSubscriptions

public PagedFlux listSubscriptions(String topicName)

Extrait tous les abonnements d’une rubrique.

Parameters:

topicName - Nom de la rubrique sous laquelle tous les abonnements doivent être récupérés.

Returns:

Flux de SubscriptionProperties pour .topicName

listTopics

public PagedFlux listTopics()

Extrait toutes les rubriques de l’espace de noms Service Bus.

Returns:

Flux de dans l’espace de TopicProperties noms Service Bus.

updateQueue

public Mono updateQueue(QueueProperties queue)

Mises à jour une file d’attente avec le donné QueueProperties. le QueueProperties doit être entièrement renseigné, car toutes les propriétés sont remplacées. Si une propriété n’est pas définie, la valeur par défaut du service est utilisée. Le flux suggéré est :

1. getQueue(String queueName)
2. Mettre à jour les éléments requis.
3. Transmettez la description mise à jour dans cette méthode.

Il existe un sous-ensemble de propriétés qui peuvent être mises à jour. Pour plus d’informations, consultez les liens ci-dessous. Il s'agit des éléments suivants :

• setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
• setLockDuration(Duration lockDuration)
• setDuplicateDetectionHistoryTimeWindow(Duration duplicateDetectionHistoryTimeWindow)
• setMaxDeliveryCount(Integer maxDeliveryCount)

Parameters:

queue - Informations sur la file d’attente à mettre à jour. Vous devez attribuer toutes les valeurs de propriétés souhaitées à l'entité mise à jour. En l'absence de valeurs, celles-ci seront définies sur les valeurs par défaut du service.

Returns:

Mono qui se termine avec la file d’attente mise à jour.

updateQueueWithResponse

public Mono<>> updateQueueWithResponse(QueueProperties queue)

Mises à jour une file d’attente avec le donné QueueProperties. le QueueProperties doit être entièrement renseigné, car toutes les propriétés sont remplacées. Si une propriété n’est pas définie, la valeur par défaut du service est utilisée. Le flux suggéré est :

1. getQueue(String queueName)
2. Mettre à jour les éléments requis.
3. Transmettez la description mise à jour dans cette méthode.

Il existe un sous-ensemble de propriétés qui peuvent être mises à jour. Pour plus d’informations, consultez les liens ci-dessous. Il s'agit des éléments suivants :

• setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
• setLockDuration(Duration lockDuration)
• setDuplicateDetectionHistoryTimeWindow(Duration duplicateDetectionHistoryTimeWindow)
• setMaxDeliveryCount(Integer maxDeliveryCount)

Parameters:

queue - Informations sur la file d’attente à mettre à jour. Vous devez attribuer toutes les valeurs de propriétés souhaitées à l'entité mise à jour. En l'absence de valeurs, celles-ci seront définies sur les valeurs par défaut du service.

Returns:

Mono qui retourne la file d’attente mise à jour en plus de la réponse HTTP.

updateRule

public Mono updateRule(String topicName, String subscriptionName, RuleProperties rule)

Mises à jour une règle avec le donné RuleProperties. le RuleProperties doit être entièrement renseigné, car toutes les propriétés sont remplacées. Si une propriété n’est pas définie, la valeur par défaut du service est utilisée. Le flux suggéré est :

1. getRule(String topicName, String subscriptionName, String ruleName)
2. Mettre à jour les éléments requis.
3. Transmettez la description mise à jour dans cette méthode.

Parameters:

topicName - Nom de la rubrique sous laquelle la règle est mise à jour.

subscriptionName - Nom de l’abonnement pour lequel la règle est mise à jour.

rule - Informations sur la règle à mettre à jour. Vous devez attribuer toutes les valeurs de propriétés souhaitées à l'entité mise à jour. En l'absence de valeurs, celles-ci seront définies sur les valeurs par défaut du service.

Returns:

Mono qui retourne la règle mise à jour.

updateRuleWithResponse

public Mono<>> updateRuleWithResponse(String topicName, String subscriptionName, RuleProperties rule)

Mises à jour une règle avec le donné RuleProperties. le RuleProperties doit être entièrement renseigné, car toutes les propriétés sont remplacées. Si une propriété n’est pas définie, la valeur par défaut du service est utilisée. Le flux suggéré est :

1. getRule(String topicName, String subscriptionName, String ruleName)
2. Mettre à jour les éléments requis.
3. Transmettez la description mise à jour dans cette méthode.

Parameters:

topicName - Nom de la rubrique sous laquelle la règle est mise à jour.

subscriptionName - Nom de l’abonnement pour lequel la règle est mise à jour.

rule - Informations sur la règle à mettre à jour. Vous devez attribuer toutes les valeurs de propriétés souhaitées à l'entité mise à jour. En l'absence de valeurs, celles-ci seront définies sur les valeurs par défaut du service.

Returns:

Mono qui retourne la règle mise à jour en plus de la réponse HTTP.

updateSubscription

public Mono updateSubscription(SubscriptionProperties subscription)

Mises à jour un abonnement avec le donné SubscriptionProperties. le SubscriptionProperties doit être entièrement renseigné, car toutes les propriétés sont remplacées. Si une propriété n’est pas définie, la valeur par défaut du service est utilisée. Le flux suggéré est :

1. getSubscription(String topicName, String subscriptionName)
2. Mettre à jour les éléments requis.
3. Transmettez la description mise à jour dans cette méthode.

Il existe un sous-ensemble de propriétés qui peuvent être mises à jour. Pour plus d’informations, consultez les liens ci-dessous. Il s'agit des éléments suivants :

• setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
• setLockDuration(Duration lockDuration)
• setMaxDeliveryCount(int maxDeliveryCount)

Parameters:

subscription - Informations sur l’abonnement à mettre à jour. Vous devez attribuer toutes les valeurs de propriétés souhaitées à l'entité mise à jour. En l'absence de valeurs, celles-ci seront définies sur les valeurs par défaut du service.

Returns:

Mono qui retourne l’abonnement mis à jour.

updateSubscriptionWithResponse

public Mono<>> updateSubscriptionWithResponse(SubscriptionProperties subscription)

Mises à jour un abonnement avec le donné SubscriptionProperties. le SubscriptionProperties doit être entièrement renseigné, car toutes les propriétés sont remplacées. Si une propriété n’est pas définie, la valeur par défaut du service est utilisée. Le flux suggéré est :

1. getSubscription(String topicName, String subscriptionName)
2. Mettre à jour les éléments requis.
3. Transmettez la description mise à jour dans cette méthode.

Il existe un sous-ensemble de propriétés qui peuvent être mises à jour. Pour plus d’informations, consultez les liens ci-dessous. Il s'agit des éléments suivants :

• setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
• setLockDuration(Duration lockDuration)
• setMaxDeliveryCount(int maxDeliveryCount)

Parameters:

subscription - Informations sur l’abonnement à mettre à jour. Vous devez attribuer toutes les valeurs de propriétés souhaitées à l'entité mise à jour. En l'absence de valeurs, celles-ci seront définies sur les valeurs par défaut du service.

Returns:

Mono qui retourne l’abonnement mis à jour en plus de la réponse HTTP.

updateTopic

public Mono updateTopic(TopicProperties topic)

Mises à jour une rubrique avec le donné TopicProperties. le TopicProperties doit être entièrement renseigné, car toutes les propriétés sont remplacées. Si une propriété n’est pas définie, la valeur par défaut du service est utilisée. Le flux suggéré est :

1. getTopic(String topicName)
2. Mettre à jour les éléments requis.
3. Transmettez la description mise à jour dans cette méthode.

Il existe un sous-ensemble de propriétés qui peuvent être mises à jour. Pour plus d’informations, consultez les liens ci-dessous. Il s'agit des éléments suivants :

• setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
• setDuplicateDetectionHistoryTimeWindow(Duration duplicateDetectionHistoryTimeWindow)

Parameters:

topic - Informations sur la rubrique à mettre à jour. Vous devez attribuer toutes les valeurs de propriétés souhaitées à l'entité mise à jour. En l'absence de valeurs, celles-ci seront définies sur les valeurs par défaut du service.

Returns:

Mono qui se termine avec la rubrique mise à jour.

updateTopicWithResponse

public Mono<>> updateTopicWithResponse(TopicProperties topic)

Mises à jour une rubrique avec le donné TopicProperties. le TopicProperties doit être entièrement renseigné, car toutes les propriétés sont remplacées. Si une propriété n’est pas définie, la valeur par défaut du service est utilisée. Le flux suggéré est :

1. getTopic(String topicName)
2. Mettre à jour les éléments requis.
3. Transmettez la description mise à jour dans cette méthode.

Il existe un sous-ensemble de propriétés qui peuvent être mises à jour. Pour plus d’informations, consultez les liens ci-dessous. Il s'agit des éléments suivants :

• setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
• setDuplicateDetectionHistoryTimeWindow(Duration duplicateDetectionHistoryTimeWindow)

Parameters:

topic - Informations sur la rubrique à mettre à jour. Vous devez attribuer toutes les valeurs de propriétés souhaitées à l'entité mise à jour. En l'absence de valeurs, celles-ci seront définies sur les valeurs par défaut du service.

Returns:

Mono qui se termine avec la rubrique mise à jour et sa réponse HTTP.