ServiceBusAdministrationAsyncClient Classe
- java.
lang. Object - com.
azure. messaging. servicebus. administration. ServiceBusAdministrationAsyncClient
- com.
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
Méthodes héritées de java.lang.Object
Détails de la méthode
createQueue
public Mono
Crée une file d’attente avec le nom donné.
Parameters:
Returns:
createQueue
public Mono
Crée une file d’attente avec le nom de file d’attente CreateQueueOptions et donné.
Parameters:
Returns:
createQueueWithResponse
public Mono
Crée une file d’attente et retourne la file d’attente créée en plus de la réponse HTTP.
Parameters:
Returns:
createRule
public Mono
Crée une règle sous la rubrique et l’abonnement donnés
Parameters:
Returns:
createRule
public Mono
Crée une règle avec .CreateRuleOptions
Parameters:
Returns:
createRuleWithResponse
public Mono
Crée une règle et retourne la règle créée en plus de la réponse HTTP.
Parameters:
Returns:
createSubscription
public Mono
Crée un abonnement avec les noms de rubrique et d’abonnement donnés.
Parameters:
Returns:
createSubscription
public Mono
Crée un abonnement avec .CreateSubscriptionOptions
Parameters:
Returns:
createSubscription
public Mono
Crée un abonnement avec une règle par défaut à l’aide de CreateSubscriptionOptions et CreateRuleOptions.
Parameters:
Returns:
createSubscriptionWithResponse
public Mono
Crée un abonnement et retourne l’abonnement créé en plus de la réponse HTTP.
Parameters:
Returns:
createSubscriptionWithResponse
public Mono
Crée un abonnement avec la règle par défaut et retourne l’abonnement créé en plus de la réponse HTTP.
Parameters:
Returns:
createTopic
public Mono
Crée une rubrique portant le nom donné.
Parameters:
Returns:
createTopic
public Mono
Crée une rubrique avec .CreateTopicOptions
Parameters:
Returns:
createTopicWithResponse
public Mono
Crée une rubrique et retourne la rubrique créée en plus de la réponse HTTP.
Parameters:
Returns:
deleteQueue
public Mono
Supprime une file d’attente correspondant à queueName
.
Parameters:
Returns:
deleteQueueWithResponse
public Mono
Supprime une file d’attente correspondant queueName
et retourne la réponse HTTP.
Parameters:
Returns:
deleteRule
public Mono
Supprime une règle correspondant ruleName
à .
Parameters:
Returns:
deleteRuleWithResponse
public Mono
Supprime une règle correspondant ruleName
et retourne la réponse HTTP.
Parameters:
Returns:
deleteSubscription
public Mono
Supprime un abonnement correspondant subscriptionName
à .
Parameters:
Returns:
deleteSubscriptionWithResponse
public Mono
Supprime un abonnement correspondant subscriptionName
et retourne la réponse HTTP.
Parameters:
Returns:
deleteTopic
public Mono
Supprime une rubrique correspondant à topicName
.
Parameters:
Returns:
deleteTopicWithResponse
public Mono
Supprime une rubrique correspondant topicName
et retourne la réponse HTTP.
Parameters:
Returns:
getNamespaceProperties
public Mono
Obtient des informations sur l’espace de noms Service Bus.
Returns:
getNamespacePropertiesWithResponse
public Mono
Obtient des informations sur l’espace de noms Service Bus ainsi que sa réponse HTTP.
Returns:
getQueue
public Mono
Obtient des informations sur la file d’attente.
Parameters:
Returns:
getQueueExists
public Mono
Obtient si une file d’attente avec queueName
existe ou non dans l’espace de noms Service Bus.
Parameters:
Returns:
getQueueExistsWithResponse
public Mono
Obtient si une file d’attente avec queueName
existe ou non dans l’espace de noms Service Bus.
Parameters:
Returns:
getQueueRuntimeProperties
public Mono
Obtient les propriétés du runtime sur la file d’attente.
Parameters:
Returns:
getQueueRuntimePropertiesWithResponse
public Mono
Obtient les propriétés d’exécution de la file d’attente ainsi que sa réponse HTTP.
Parameters:
Returns:
getQueueWithResponse
public Mono
Obtient des informations sur la file d’attente ainsi que sa réponse HTTP.
Parameters:
Returns:
getRule
public Mono
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:
Returns:
getRuleWithResponse
public Mono
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:
Returns:
getSubscription
public Mono
Obtient des informations sur la file d’attente.
Parameters:
Returns:
getSubscriptionExists
public Mono
Obtient si un abonnement dans une rubrique existe ou non.
Parameters:
Returns:
getSubscriptionExistsWithResponse
public Mono
Obtient si un abonnement dans une rubrique existe ou non.
Parameters:
Returns:
getSubscriptionRuntimeProperties
public Mono
Obtient les propriétés d’exécution relatives à l’abonnement.
Parameters:
Returns:
getSubscriptionRuntimePropertiesWithResponse
public Mono
Obtient les propriétés d’exécution relatives à l’abonnement.
Parameters:
Returns:
getSubscriptionWithResponse
public Mono
Obtient des informations sur l’abonnement ainsi que sa réponse HTTP.
Parameters:
Returns:
getTopic
public Mono
Obtient des informations sur la rubrique.
Parameters:
Returns:
getTopicExists
public Mono
Obtient si une rubrique avec topicName
existe ou non dans l’espace de noms Service Bus.
Parameters:
Returns:
getTopicExistsWithResponse
public Mono
Obtient si une rubrique avec topicName
existe ou non dans l’espace de noms Service Bus.
Parameters:
Returns:
getTopicRuntimeProperties
public Mono
Obtient les propriétés d’exécution relatives à la rubrique .
Parameters:
Returns:
getTopicRuntimePropertiesWithResponse
public Mono
Obtient les propriétés d’exécution de la rubrique avec sa réponse HTTP.
Parameters:
Returns:
getTopicWithResponse
public Mono
Obtient des informations sur la rubrique ainsi que sa réponse HTTP.
Parameters:
Returns:
listQueues
public PagedFlux
Extrait toutes les files d’attente dans l’espace de noms Service Bus.
Returns:
listRules
public PagedFlux
Extrait toutes les règles d’une rubrique et d’un abonnement.
Parameters:
Returns:
listSubscriptions
public PagedFlux
Extrait tous les abonnements d’une rubrique.
Parameters:
Returns:
topicName
listTopics
public PagedFlux
Extrait toutes les rubriques de l’espace de noms Service Bus.
Returns:
updateQueue
public Mono
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 :
- getQueue(String queueName)
- Mettre à jour les éléments requis.
- 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:
Returns:
updateQueueWithResponse
public Mono
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 :
- getQueue(String queueName)
- Mettre à jour les éléments requis.
- 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:
Returns:
updateRule
public Mono
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 :
- getRule(String topicName, String subscriptionName, String ruleName)
- Mettre à jour les éléments requis.
- Transmettez la description mise à jour dans cette méthode.
Parameters:
Returns:
updateRuleWithResponse
public Mono
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 :
- getRule(String topicName, String subscriptionName, String ruleName)
- Mettre à jour les éléments requis.
- Transmettez la description mise à jour dans cette méthode.
Parameters:
Returns:
updateSubscription
public Mono
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 :
- getSubscription(String topicName, String subscriptionName)
- Mettre à jour les éléments requis.
- 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:
Returns:
updateSubscriptionWithResponse
public Mono
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 :
- getSubscription(String topicName, String subscriptionName)
- Mettre à jour les éléments requis.
- 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:
Returns:
updateTopic
public Mono
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 :
- getTopic(String topicName)
- Mettre à jour les éléments requis.
- 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:
Returns:
updateTopicWithResponse
public Mono
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 :
- getTopic(String topicName)
- Mettre à jour les éléments requis.
- 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:
Returns:
S’applique à
Azure SDK for Java