Freigeben über

ServiceBusRuleManagerAsyncClient Klasse

  • Referenz
Paket:
com.azure.messaging.servicebus
Maven-Artefakt:
com.azure:azure-messaging-servicebus:7.17.0
  • java.lang.Object
    • com.azure.messaging.servicebus.ServiceBusRuleManagerAsyncClient

Implementiert

AutoCloseable

public class ServiceBusRuleManagerAsyncClient
implements AutoCloseable

Ein asynchroner Regel-Manager, der für die Verwaltung von Regeln für ein bestimmtes Themenabonnement verantwortlich ist. Der Regel-Manager erfordert nur Listen-Ansprüche, während für " ServiceBusAdministrationAsyncClient Ansprüche verwalten" erforderlich ist.

Erstellen eines instance des Regel-Managers

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

Erstellen einer Regel für ein Service Bus-Abonnement

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();

Ruft alle Regeln ab.

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

Löschen sie eine Regel.

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

Methodenzusammenfassung

Modifizierer und Typ Methode und Beschreibung
void close()

Veräußert den ServiceBusRuleManagerAsyncClient.
Mono<Void> createRule(String ruleName, CreateRuleOptions options)

Erstellt eine Regel für das aktuelle Abonnement, um die Nachrichten zu filtern, die vom Thema an das Abonnement reichen.
Mono<Void> deleteRule(String ruleName)

Entfernt die Regel für das durch identifizierte ruleNameAbonnement.
String getEntityPath()

Ruft den Namen der Service Bus-Ressource ab.
String getFullyQualifiedNamespace()

Ruft den vollqualifizierten Namespace ab.
Flux<RuleProperties> listRules()

Ruft alle Regeln ab, die dem Thema und dem Abonnement zugeordnet sind.

Geerbte Methoden von java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Details zur Methode

close

public void close()

Veräußert den ServiceBusRuleManagerAsyncClient. Wenn der Client über eine dedizierte Verbindung verfügt, wird auch die zugrunde liegende Verbindung geschlossen.

createRule

public Mono createRule(String ruleName, CreateRuleOptions options)

Erstellt eine Regel für das aktuelle Abonnement, um die Nachrichten zu filtern, die vom Thema an das Abonnement reichen.

Parameters:

ruleName - Name der Regel.
options - Die Optionen für die hinzuzufügende Regel.

Returns:

Ein Mono-Wert, der abgeschlossen wird, wenn die Regel erstellt wird.

deleteRule

public Mono deleteRule(String ruleName)

Entfernt die Regel für das durch identifizierte ruleNameAbonnement.

Parameters:

ruleName - Name der zu löschenden Regel.

Returns:

Ein Mono-Element, das abgeschlossen wird, wenn die Regel gelöscht wird.

getEntityPath

public String getEntityPath()

Ruft den Namen der Service Bus-Ressource ab.

Returns:

Der Name der Service Bus-Ressource.

getFullyQualifiedNamespace

public String getFullyQualifiedNamespace()

Ruft den vollqualifizierten Namespace ab.

Returns:

Der vollqualifizierte Namespace.

listRules

public Flux listRules()

Ruft alle Regeln ab, die dem Thema und dem Abonnement zugeordnet sind.

Returns:

Eine Liste der Regeln, die dem Thema und dem Abonnement zugeordnet sind.

Gilt für: