Partager via

ServiceBusRuleManagerAsyncClient Classe

  • Référence
Paquet:
com.azure.messaging.servicebus
Artefact Maven:
com.azure:azure-messaging-servicebus:7.17.0
  • java.lang.Object
    • com.azure.messaging.servicebus.ServiceBusRuleManagerAsyncClient

Implémente

Closeable automatiquement

public class ServiceBusRuleManagerAsyncClient
implements AutoCloseable

Gestionnaire de règles asynchrone responsable de la gestion des règles pour un abonnement à une rubrique spécifique. Le gestionnaire de règles requiert uniquement les revendications Listen, tandis que le ServiceBusAdministrationAsyncClient nécessite Gérer les revendications.

Créer un instance de gestionnaire de règles

// The required parameters is connectionString, a way to authenticate with Service Bus using credentials.
 // The connectionString/queueName must be set by the application. The 'connectionString' format is shown below.
 // "Endpoint={fully-qualified-namespace};SharedAccessKeyName={policy-name};SharedAccessKey={key}"
 TokenCredential credential = new DefaultAzureCredentialBuilder().build();

 // 'fullyQualifiedNamespace' will look similar to "{your-namespace}.servicebus.windows.net"
 ServiceBusRuleManagerAsyncClient ruleManager = new ServiceBusClientBuilder()
     .credential(fullyQualifiedNamespace, credential)
     .ruleManager()
     .topicName(topicName)
     .subscriptionName(subscriptionName)
     .buildAsyncClient();

Créer une règle pour un abonnement Service Bus

RuleFilter trueRuleFilter = new TrueRuleFilter();
 CreateRuleOptions options = new CreateRuleOptions(trueRuleFilter);

 // `subscribe` is a non-blocking call. After setting up the create rule operation, it will move onto the next
 // line of code to execute.
 // Consider using Mono.usingWhen to scope the creation, usage, and cleanup of the rule manager.
 ruleManager.createRule("new-rule", options).subscribe(
     unused -> {
     },
     err -> System.err.println("Error occurred when create a rule, err: " + err),
     () -> System.out.println("Create complete.")
 );

 // Finally dispose of the rule manager when done using it.
 ruleManager.close();

Récupérez toutes les règles.

// `subscribe` is a non-blocking call. After setting up the list rules operation, it will move onto the next
 // line of code to execute.
 ruleManager.listRules().subscribe(ruleProperties -> System.out.println(ruleProperties.getName()));

Supprimer une règle.

// `subscribe` is a non-blocking call. After setting up the delete rule operation, it will move onto the next
 // line of code to execute.
 ruleManager.deleteRule("exist-rule").subscribe(
     unused -> { },
     err -> System.err.println("Error occurred when delete rule, err: " + err),
     () -> System.out.println("Delete complete.")
 );

Résumé de la méthode

Modificateur et type Méthode et description
void close()

Supprime le ServiceBusRuleManagerAsyncClient.
Mono<Void> createRule(String ruleName, CreateRuleOptions options)

Crée une règle pour l’abonnement actuel pour filtrer les messages qui arrivent de la rubrique à l’abonnement.
Mono<Void> deleteRule(String ruleName)

Supprime la règle sur l’abonnement identifié par ruleName.
String getEntityPath()

Obtient le nom de la ressource Service Bus.
String getFullyQualifiedNamespace()

Obtient l’espace de noms complet.
Flux<RuleProperties> listRules()

Récupère toutes les règles associées à la rubrique et à l’abonnement.

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

close

public void close()

Supprime le ServiceBusRuleManagerAsyncClient. Si le client dispose d’une connexion dédiée, la connexion sous-jacente est également fermée.

createRule

public Mono createRule(String ruleName, CreateRuleOptions options)

Crée une règle pour l’abonnement actuel pour filtrer les messages qui arrivent de la rubrique à l’abonnement.

Parameters:

ruleName - Nom de la règle.
options - Options de la règle à ajouter.

Returns:

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

deleteRule

public Mono deleteRule(String ruleName)

Supprime la règle sur l’abonnement identifié par ruleName.

Parameters:

ruleName - Nom de la règle à supprimer.

Returns:

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

getEntityPath

public String getEntityPath()

Obtient le nom de la ressource Service Bus.

Returns:

Nom de la ressource Service Bus.

getFullyQualifiedNamespace

public String getFullyQualifiedNamespace()

Obtient l’espace de noms complet.

Returns:

Espace de noms complet.

listRules

public Flux listRules()

Récupère toutes les règles associées à la rubrique et à l’abonnement.

Returns:

Liste des règles associées à la rubrique et à l’abonnement.

S’applique à