Freigeben über

ServiceBusAdministrationAsyncClient Klasse

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

public final class ServiceBusAdministrationAsyncClient

Ein asynchroner Client zum Verwalten eines Service Bus-Namespaces. Instanziiert über ServiceBusAdministrationClientBuilder.

Beispiel: Erstellen des asynchronen Clients

Im folgenden Codebeispiel wird die Erstellung des asynchronen Verwaltungsclients veranschaulicht. Die im folgenden Beispiel verwendeten Anmeldeinformationen dienen DefaultAzureCredential der Authentifizierung. Es eignet sich für die meisten Szenarien, einschließlich lokaler Entwicklungs- und Produktionsumgebungen. Darüber hinaus wird empfohlen, die verwaltete Identität für die Authentifizierung in Produktionsumgebungen zu verwenden. Weitere Informationen zu verschiedenen Authentifizierungsmethoden und den entsprechenden Anmeldeinformationstypen finden Sie in der Dokumentation zu 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();

Beispiel: Erstellen einer Warteschlange

Im folgenden Beispiel wird eine Warteschlange mit Standardwerten erstellt. Standardwerte werden in CreateQueueOptions()aufgeführt.

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

Beispiel: Bearbeiten eines vorhandenen Abonnements

Im folgenden Codebeispiel wird das Aktualisieren eines vorhandenen Abonnements veranschaulicht. Benutzer sollten die Eigenschaften des Abonnements abrufen, die Eigenschaften ändern und das Objekt dann an die Updatemethode übergeben.

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

Beispiel: Auflisten aller Warteschlangen

Im folgenden Codebeispiel werden alle Warteschlangen im Service Bus-Namespace aufgelistet.

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

Beispiel: Warteschlange löschen

Im folgenden Codebeispiel wird das Löschen einer vorhandenen Warteschlange veranschaulicht.

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

Methodenzusammenfassung

Modifizierer und Typ Methode und Beschreibung
Mono<QueueProperties> createQueue(String queueName)

Erstellt eine Warteschlange mit dem angegebenen Namen.
Mono<QueueProperties> createQueue(String queueName, CreateQueueOptions queueOptions)

Erstellt eine Warteschlange mit dem und dem CreateQueueOptions angegebenen Warteschlangennamen.
Mono<Response<QueueProperties>> createQueueWithResponse(String queueName, CreateQueueOptions queueOptions)

Erstellt eine Warteschlange und gibt die erstellte Warteschlange zusätzlich zur HTTP-Antwort zurück.
Mono<RuleProperties> createRule(String topicName, String subscriptionName, String ruleName)

Erstellt eine Regel unter dem angegebenen Thema und Abonnement.
Mono<RuleProperties> createRule(String topicName, String subscriptionName, String ruleName, CreateRuleOptions ruleOptions)

Erstellt eine Regel mit .CreateRuleOptions
Mono<Response<RuleProperties>> createRuleWithResponse(String topicName, String subscriptionName, String ruleName, CreateRuleOptions ruleOptions)

Erstellt eine Regel und gibt die erstellte Regel zusätzlich zur HTTP-Antwort zurück.
Mono<SubscriptionProperties> createSubscription(String topicName, String subscriptionName)

Erstellt ein Abonnement mit dem angegebenen Thema und den angegebenen Abonnementnamen.
Mono<SubscriptionProperties> createSubscription(String topicName, String subscriptionName, CreateSubscriptionOptions subscriptionOptions)

Erstellt ein Abonnement mit .CreateSubscriptionOptions
Mono<SubscriptionProperties> createSubscription(String topicName, String subscriptionName, String ruleName, CreateSubscriptionOptions subscriptionOptions, CreateRuleOptions ruleOptions)

Erstellt ein Abonnement mit einer Standardregel mit CreateSubscriptionOptions und CreateRuleOptions.
Mono<Response<SubscriptionProperties>> createSubscriptionWithResponse(String topicName, String subscriptionName, CreateSubscriptionOptions subscriptionOptions)

Erstellt ein Abonnement und gibt das erstellte Abonnement zusätzlich zur HTTP-Antwort zurück.
Mono<Response<SubscriptionProperties>> createSubscriptionWithResponse(String topicName, String subscriptionName, String ruleName, CreateSubscriptionOptions subscriptionOptions, CreateRuleOptions ruleOptions)

Erstellt ein Abonnement mit der Standardregel und gibt das erstellte Abonnement zusätzlich zur HTTP-Antwort zurück.
Mono<TopicProperties> createTopic(String topicName)

Erstellt ein Thema mit dem angegebenen Namen.
Mono<TopicProperties> createTopic(String topicName, CreateTopicOptions topicOptions)

Erstellt ein Thema mit .CreateTopicOptions
Mono<Response<TopicProperties>> createTopicWithResponse(String topicName, CreateTopicOptions topicOptions)

Erstellt ein Thema und gibt das erstellte Thema zusätzlich zur HTTP-Antwort zurück.
Mono<Void> deleteQueue(String queueName)

Löscht eine Warteschlange mit dem übereinstimmenden queueName.
Mono<Response<Void>> deleteQueueWithResponse(String queueName)

Löscht die übereinstimmende queueName Warteschlange und gibt die HTTP-Antwort zurück.
Mono<Void> deleteRule(String topicName, String subscriptionName, String ruleName)

Löscht eine Regel mit dem übereinstimmenden ruleName.
Mono<Response<Void>> deleteRuleWithResponse(String topicName, String subscriptionName, String ruleName)

Löscht die übereinstimmende ruleName Regel und gibt die HTTP-Antwort zurück.
Mono<Void> deleteSubscription(String topicName, String subscriptionName)

Löscht ein Abonnement mit dem übereinstimmenden subscriptionName.
Mono<Response<Void>> deleteSubscriptionWithResponse(String topicName, String subscriptionName)

Löscht das übereinstimmende subscriptionName Abonnement und gibt die HTTP-Antwort zurück.
Mono<Void> deleteTopic(String topicName)

Löscht ein Thema mit dem übereinstimmenden topicName.
Mono<Response<Void>> deleteTopicWithResponse(String topicName)

Löscht das übereinstimmende topicName Thema und gibt die HTTP-Antwort zurück.
Mono<NamespaceProperties> getNamespaceProperties()

Ruft Informationen zum Service Bus-Namespace ab.
Mono<Response<NamespaceProperties>> getNamespacePropertiesWithResponse()

Ruft Informationen zum Service Bus-Namespace zusammen mit seiner HTTP-Antwort ab.
Mono<QueueProperties> getQueue(String queueName)

Ruft Informationen zur Warteschlange ab.
Mono<Boolean> getQueueExists(String queueName)

Ruft ab, ob eine Warteschlange mit queueName im Service Bus-Namespace vorhanden ist.
Mono<Response<Boolean>> getQueueExistsWithResponse(String queueName)

Ruft ab, ob eine Warteschlange mit queueName im Service Bus-Namespace vorhanden ist.
Mono<QueueRuntimeProperties> getQueueRuntimeProperties(String queueName)

Ruft Laufzeiteigenschaften zur Warteschlange ab.
Mono<Response<QueueRuntimeProperties>> getQueueRuntimePropertiesWithResponse(String queueName)

Ruft Laufzeiteigenschaften zur Warteschlange zusammen mit ihrer HTTP-Antwort ab.
Mono<Response<QueueProperties>> getQueueWithResponse(String queueName)

Ruft Informationen zur Warteschlange zusammen mit ihrer HTTP-Antwort ab.
Mono<RuleProperties> getRule(String topicName, String subscriptionName, String ruleName)

Ruft eine Regel aus dem Dienstnamespace ab.
Mono<Response<RuleProperties>> getRuleWithResponse(String topicName, String subscriptionName, String ruleName)

Ruft eine Regel aus dem Dienstnamespace ab.
Mono<SubscriptionProperties> getSubscription(String topicName, String subscriptionName)

Ruft Informationen zur Warteschlange ab.
Mono<Boolean> getSubscriptionExists(String topicName, String subscriptionName)

Ruft ab, ob ein Abonnement innerhalb eines Themas vorhanden ist.
Mono<Response<Boolean>> getSubscriptionExistsWithResponse(String topicName, String subscriptionName)

Ruft ab, ob ein Abonnement innerhalb eines Themas vorhanden ist.
Mono<SubscriptionRuntimeProperties> getSubscriptionRuntimeProperties(String topicName, String subscriptionName)

Ruft Laufzeiteigenschaften für das Abonnement ab.
Mono<Response<SubscriptionRuntimeProperties>> getSubscriptionRuntimePropertiesWithResponse(String topicName, String subscriptionName)

Ruft Laufzeiteigenschaften für das Abonnement ab.
Mono<Response<SubscriptionProperties>> getSubscriptionWithResponse(String topicName, String subscriptionName)

Ruft Informationen zum Abonnement zusammen mit seiner HTTP-Antwort ab.
Mono<TopicProperties> getTopic(String topicName)

Ruft Informationen zum Thema ab.
Mono<Boolean> getTopicExists(String topicName)

Ruft ab, ob ein Thema mit topicName im Service Bus-Namespace vorhanden ist.
Mono<Response<Boolean>> getTopicExistsWithResponse(String topicName)

Ruft ab, ob ein Thema mit topicName im Service Bus-Namespace vorhanden ist.
Mono<TopicRuntimeProperties> getTopicRuntimeProperties(String topicName)

Ruft Laufzeiteigenschaften zum Thema ab.
Mono<Response<TopicRuntimeProperties>> getTopicRuntimePropertiesWithResponse(String topicName)

Ruft Laufzeiteigenschaften zum Thema mit seiner HTTP-Antwort ab.
Mono<Response<TopicProperties>> getTopicWithResponse(String topicName)

Ruft Informationen zum Thema zusammen mit der HTTP-Antwort ab.
PagedFlux<QueueProperties> listQueues()

Ruft alle Warteschlangen im Service Bus-Namespace ab.
PagedFlux<RuleProperties> listRules(String topicName, String subscriptionName)

Ruft alle Regeln für ein Thema und ein Abonnement ab.
PagedFlux<SubscriptionProperties> listSubscriptions(String topicName)

Ruft alle Abonnements für ein Thema ab.
PagedFlux<TopicProperties> listTopics()

Ruft alle Themen im Service Bus-Namespace ab.
Mono<QueueProperties> updateQueue(QueueProperties queue)

Updates eine Warteschlange mit dem angegebenen QueueProperties.
Mono<Response<QueueProperties>> updateQueueWithResponse(QueueProperties queue)

Updates eine Warteschlange mit dem angegebenen QueueProperties.
Mono<RuleProperties> updateRule(String topicName, String subscriptionName, RuleProperties rule)

Updates eine Regel mit dem angegebenen RuleProperties.
Mono<Response<RuleProperties>> updateRuleWithResponse(String topicName, String subscriptionName, RuleProperties rule)

Updates eine Regel mit dem angegebenen RuleProperties.
Mono<SubscriptionProperties> updateSubscription(SubscriptionProperties subscription)

Updates ein Abonnement mit dem angegebenen SubscriptionProperties.
Mono<Response<SubscriptionProperties>> updateSubscriptionWithResponse(SubscriptionProperties subscription)

Updates ein Abonnement mit dem angegebenen SubscriptionProperties.
Mono<TopicProperties> updateTopic(TopicProperties topic)

Updates ein Thema mit dem angegebenen TopicProperties.
Mono<Response<TopicProperties>> updateTopicWithResponse(TopicProperties topic)

Updates ein Thema mit dem angegebenen TopicProperties.

Geerbte Methoden von java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Details zur Methode

createQueue

public Mono createQueue(String queueName)

Erstellt eine Warteschlange mit dem angegebenen Namen.

Parameters:

queueName - Name der zu erstellenden Warteschlange.

Returns:

Ein Mono, der mit Informationen zur erstellten Warteschlange abgeschlossen wird.

createQueue

public Mono createQueue(String queueName, CreateQueueOptions queueOptions)

Erstellt eine Warteschlange mit dem und dem CreateQueueOptions angegebenen Warteschlangennamen.

Parameters:

queueName - Name der zu erstellenden Warteschlange.
queueOptions - Optionen zur zu erstellenden Warteschlange.

Returns:

Ein Mono, der mit Informationen zur erstellten Warteschlange abgeschlossen wird.

createQueueWithResponse

public Mono> createQueueWithResponse(String queueName, CreateQueueOptions queueOptions)

Erstellt eine Warteschlange und gibt die erstellte Warteschlange zusätzlich zur HTTP-Antwort zurück.

Parameters:

queueName - Name der zu erstellenden Warteschlange.
queueOptions - Optionen zur zu erstellenden Warteschlange.

Returns:

Ein Mono-Element, das die erstellte Warteschlange zusätzlich zur HTTP-Antwort zurückgibt.

createRule

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

Erstellt eine Regel unter dem angegebenen Thema und Abonnement.

Parameters:

topicName - Name des Themas, das der Regel zugeordnet ist.
subscriptionName - Name des Abonnements, das der Regel zugeordnet ist.
ruleName - Name der Regel.

Returns:

Ein Mono, der mit Informationen zur erstellten Regel ergänzt wird.

createRule

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

Erstellt eine Regel mit .CreateRuleOptions

Parameters:

topicName - Name des Themas, das der Regel zugeordnet ist.
subscriptionName - Name des Abonnements, das der Regel zugeordnet ist.
ruleName - Name der Regel.
ruleOptions - Informationen zur zu erstellenden Regel.

Returns:

Ein Mono, der mit Informationen zur erstellten Regel ergänzt wird.

createRuleWithResponse

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

Erstellt eine Regel und gibt die erstellte Regel zusätzlich zur HTTP-Antwort zurück.

Parameters:

topicName - Name des Themas, das der Regel zugeordnet ist.
subscriptionName - Name des Abonnements, das der Regel zugeordnet ist.
ruleName - Name der Regel.
ruleOptions - Informationen zur zu erstellenden Regel.

Returns:

Ein Mono-Element, das die erstellte Regel zusätzlich zur HTTP-Antwort zurückgibt.

createSubscription

public Mono createSubscription(String topicName, String subscriptionName)

Erstellt ein Abonnement mit dem angegebenen Thema und den angegebenen Abonnementnamen.

Parameters:

topicName - Name des Themas, das dem Abonnement zugeordnet ist.
subscriptionName - Name des Abonnements.

Returns:

Eine Mono-Datei, die mit Informationen zum erstellten Abonnement ergänzt wird.

createSubscription

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

Erstellt ein Abonnement mit .CreateSubscriptionOptions

Parameters:

topicName - Name des Themas, das dem Abonnement zugeordnet ist.
subscriptionName - Name des Abonnements.
subscriptionOptions - Informationen zum zu erstellenden Abonnement.

Returns:

Eine Mono-Datei, die mit Informationen zum erstellten Abonnement ergänzt wird.

createSubscription

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

Erstellt ein Abonnement mit einer Standardregel mit CreateSubscriptionOptions und CreateRuleOptions.

Parameters:

topicName - Name des Themas, das dem Abonnement zugeordnet ist.
subscriptionName - Name des Abonnements.
ruleName - Name der Standardregel, mit der das Abonnement erstellt werden soll.
subscriptionOptions - Ein CreateSubscriptionOptions Objekt, das das zu erstellende Abonnement beschreibt.
ruleOptions - Ein CreateRuleOptions Objekt, das die Standardregel beschreibt. Wenn NULL ist, wird ein Passthroughfilter erstellt.

Returns:

Eine Mono-Datei, die mit Informationen zum erstellten Abonnement ergänzt wird.

createSubscriptionWithResponse

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

Erstellt ein Abonnement und gibt das erstellte Abonnement zusätzlich zur HTTP-Antwort zurück.

Parameters:

topicName - Name des Themas, das dem Abonnement zugeordnet ist.
subscriptionName - Name des Abonnements.
subscriptionOptions - Informationen zum zu erstellenden Abonnement.

Returns:

Ein Mono-Objekt, das das erstellte Abonnement zusätzlich zur HTTP-Antwort zurückgibt.

createSubscriptionWithResponse

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

Erstellt ein Abonnement mit der Standardregel und gibt das erstellte Abonnement zusätzlich zur HTTP-Antwort zurück.

Parameters:

topicName - Name des Themas, das dem Abonnement zugeordnet ist.
subscriptionName - Name des Abonnements.
ruleName - Name der Standardregel, mit der das Abonnement erstellt werden soll.
subscriptionOptions - Ein CreateSubscriptionOptions Objekt, das das zu erstellende Abonnement beschreibt.
ruleOptions - Ein CreateRuleOptions Objekt, das die Standardregel beschreibt. Wenn NULL ist, wird ein Passthroughfilter erstellt.

Returns:

Ein Mono-Objekt, das das erstellte Abonnement zusätzlich zur HTTP-Antwort zurückgibt.

createTopic

public Mono createTopic(String topicName)

Erstellt ein Thema mit dem angegebenen Namen.

Parameters:

topicName - Name des zu erstellenden Themas.

Returns:

Ein Mono, der mit Informationen zum erstellten Thema ergänzt wird.

createTopic

public Mono createTopic(String topicName, CreateTopicOptions topicOptions)

Erstellt ein Thema mit .CreateTopicOptions

Parameters:

topicName - Name des zu erstellenden Themas.
topicOptions - Die Zum Erstellen des Themas verwendeten Optionen.

Returns:

Ein Mono, der mit Informationen zum erstellten Thema ergänzt wird.

createTopicWithResponse

public Mono> createTopicWithResponse(String topicName, CreateTopicOptions topicOptions)

Erstellt ein Thema und gibt das erstellte Thema zusätzlich zur HTTP-Antwort zurück.

Parameters:

topicName - Name des zu erstellenden Themas.
topicOptions - Die Zum Erstellen des Themas verwendeten Optionen.

Returns:

Ein Mono-Objekt, das das erstellte Thema zusätzlich zur HTTP-Antwort zurückgibt.

deleteQueue

public Mono deleteQueue(String queueName)

Löscht eine Warteschlange mit dem übereinstimmenden queueName.

Parameters:

queueName - Name der zu löschenden Warteschlange.

Returns:

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

deleteQueueWithResponse

public Mono> deleteQueueWithResponse(String queueName)

Löscht die übereinstimmende queueName Warteschlange und gibt die HTTP-Antwort zurück.

Parameters:

queueName - Name der zu löschenden Warteschlange.

Returns:

Ein Mono-Element, das abgeschlossen wird, wenn die Warteschlange gelöscht wird und die HTTP-Antwort zurückgibt.

deleteRule

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

Löscht eine Regel mit dem übereinstimmenden ruleName.

Parameters:

topicName - Name des Themas, das der zu löschenden Regel zugeordnet ist.
subscriptionName - Name des Abonnements, das der zu löschenden Regel zugeordnet ist.
ruleName - Name der zu löschenden Regel.

Returns:

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

deleteRuleWithResponse

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

Löscht die übereinstimmende ruleName Regel und gibt die HTTP-Antwort zurück.

Parameters:

topicName - Name des Themas, das der zu löschenden Regel zugeordnet ist.
subscriptionName - Name des Abonnements, das der zu löschenden Regel zugeordnet ist.
ruleName - Name der zu löschenden Regel.

Returns:

Ein Mono-Element, das abgeschlossen wird, wenn die Regel gelöscht wird und die HTTP-Antwort zurückgibt.

deleteSubscription

public Mono deleteSubscription(String topicName, String subscriptionName)

Löscht ein Abonnement mit dem übereinstimmenden subscriptionName.

Parameters:

topicName - Name des Themas, das dem zu löschenden Abonnement zugeordnet ist.
subscriptionName - Name des zu löschenden Abonnements.

Returns:

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

deleteSubscriptionWithResponse

public Mono> deleteSubscriptionWithResponse(String topicName, String subscriptionName)

Löscht das übereinstimmende subscriptionName Abonnement und gibt die HTTP-Antwort zurück.

Parameters:

topicName - Name des Themas, das dem zu löschenden Abonnement zugeordnet ist.
subscriptionName - Name des zu löschenden Abonnements.

Returns:

Ein Mono,der abgeschlossen wird, wenn das Abonnement gelöscht wird und die HTTP-Antwort zurückgibt.

deleteTopic

public Mono deleteTopic(String topicName)

Löscht ein Thema mit dem übereinstimmenden topicName.

Parameters:

topicName - Name des zu löschenden Themas.

Returns:

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

deleteTopicWithResponse

public Mono> deleteTopicWithResponse(String topicName)

Löscht das übereinstimmende topicName Thema und gibt die HTTP-Antwort zurück.

Parameters:

topicName - Name des zu löschenden Themas.

Returns:

Ein Mono, der abgeschlossen wird, wenn das Thema gelöscht wird und die HTTP-Antwort zurückgibt.

getNamespaceProperties

public Mono getNamespaceProperties()

Ruft Informationen zum Service Bus-Namespace ab.

Returns:

Ein Mono-Wert, der mit Informationen zum Service Bus-Namespace ergänzt wird.

getNamespacePropertiesWithResponse

public Mono> getNamespacePropertiesWithResponse()

Ruft Informationen zum Service Bus-Namespace zusammen mit seiner HTTP-Antwort ab.

Returns:

Ein Mono-Wert, der mit Informationen zum Namespace und der zugehörigen HTTP-Antwort abgeschlossen wird.

getQueue

public Mono getQueue(String queueName)

Ruft Informationen zur Warteschlange ab.

Parameters:

queueName - Name der Warteschlange, über die Informationen abgerufen werden sollen.

Returns:

Ein Mono, der mit Informationen zur Warteschlange abgeschlossen wird.

getQueueExists

public Mono getQueueExists(String queueName)

Ruft ab, ob eine Warteschlange mit queueName im Service Bus-Namespace vorhanden ist.

Parameters:

queueName - Name der Warteschlange.

Returns:

Ein Mono,der abgeschlossen ist, der angibt, ob die Warteschlange vorhanden ist.

getQueueExistsWithResponse

public Mono> getQueueExistsWithResponse(String queueName)

Ruft ab, ob eine Warteschlange mit queueName im Service Bus-Namespace vorhanden ist.

Parameters:

queueName - Name der Warteschlange.

Returns:

Eine Mono-Instanz, die angibt, ob die Warteschlange zusammen mit der HTTP-Antwort vorhanden ist oder nicht.

getQueueRuntimeProperties

public Mono getQueueRuntimeProperties(String queueName)

Ruft Laufzeiteigenschaften zur Warteschlange ab.

Parameters:

queueName - Name der Warteschlange, über die Informationen abgerufen werden sollen.

Returns:

Ein Mono, der mit Laufzeiteigenschaften zur Warteschlange abgeschlossen wird.

getQueueRuntimePropertiesWithResponse

public Mono> getQueueRuntimePropertiesWithResponse(String queueName)

Ruft Laufzeiteigenschaften zur Warteschlange zusammen mit ihrer HTTP-Antwort ab.

Parameters:

queueName - Name der Warteschlange, über die Informationen abgerufen werden sollen.

Returns:

Ein Mono-Element, das mit Laufzeiteigenschaften zur Warteschlange und der zugehörigen HTTP-Antwort abgeschlossen wird.

getQueueWithResponse

public Mono> getQueueWithResponse(String queueName)

Ruft Informationen zur Warteschlange zusammen mit ihrer HTTP-Antwort ab.

Parameters:

queueName - Name der Warteschlange, über die Informationen abgerufen werden sollen.

Returns:

Ein Mono, der mit Informationen zur Warteschlange und der zugehörigen HTTP-Antwort abgeschlossen wird.

getRule

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

Ruft eine Regel aus dem Dienstnamespace ab. Nur die folgenden Datentypen werden in Filter und Aktionsparametern deserialisiert: string, int, long, boolean, double und OffsetDateTime. Andere Datentypen geben den Zeichenfolgenwert zurück.

Parameters:

topicName - Der Name des Themas relativ zum Service Bus-Namespace.
subscriptionName - Der Abonnementname, zu dem die Regel gehört.
ruleName - Der Name der abzurufenden Regel.

Returns:

Die zugeordnete Regel.

getRuleWithResponse

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

Ruft eine Regel aus dem Dienstnamespace ab. Nur die folgenden Datentypen werden in Filter und Aktionsparametern deserialisiert: string, int, long, bool, double und OffsetDateTime. Andere Datentypen geben den Zeichenfolgenwert zurück.

Parameters:

topicName - Der Name des Themas relativ zum Service Bus-Namespace.
subscriptionName - Der Abonnementname, zu dem die Regel gehört.
ruleName - Der Name der abzurufenden Regel.

Returns:

Die zugeordnete Regel mit der entsprechenden HTTP-Antwort.

getSubscription

public Mono getSubscription(String topicName, String subscriptionName)

Ruft Informationen zur Warteschlange ab.

Parameters:

topicName - Name des Themas, das dem Abonnement zugeordnet ist.
subscriptionName - Name des Abonnements, zu dem Informationen abgerufen werden sollen.

Returns:

Ein Mono-Typ, der mit Informationen zum Abonnement ergänzt wird.

getSubscriptionExists

public Mono getSubscriptionExists(String topicName, String subscriptionName)

Ruft ab, ob ein Abonnement innerhalb eines Themas vorhanden ist.

Parameters:

topicName - Name des Themas, das dem Abonnement zugeordnet ist.
subscriptionName - Name des Abonnements.

Returns:

Ein Mono-Wert, der abgeschlossen wird, der angibt, ob das Abonnement vorhanden ist oder nicht.

getSubscriptionExistsWithResponse

public Mono> getSubscriptionExistsWithResponse(String topicName, String subscriptionName)

Ruft ab, ob ein Abonnement innerhalb eines Themas vorhanden ist.

Parameters:

topicName - Name des Themas, das dem Abonnement zugeordnet ist.
subscriptionName - Name des Abonnements.

Returns:

Ein Mono-Wert, der abgeschlossen wird, der angibt, ob das Abonnement zusammen mit seiner HTTP-Antwort vorhanden ist.

getSubscriptionRuntimeProperties

public Mono getSubscriptionRuntimeProperties(String topicName, String subscriptionName)

Ruft Laufzeiteigenschaften für das Abonnement ab.

Parameters:

topicName - Name des Themas, das dem Abonnement zugeordnet ist.
subscriptionName - Name des Abonnements, zu dem Informationen abgerufen werden sollen.

Returns:

Ein Mono-Element, das mit Laufzeiteigenschaften für das Abonnement abgeschlossen wird.

getSubscriptionRuntimePropertiesWithResponse

public Mono> getSubscriptionRuntimePropertiesWithResponse(String topicName, String subscriptionName)

Ruft Laufzeiteigenschaften für das Abonnement ab.

Parameters:

topicName - Name des Themas, das dem Abonnement zugeordnet ist.
subscriptionName - Name des Abonnements, zu dem Informationen abgerufen werden sollen.

Returns:

Ein Mono-Element, das mit Laufzeiteigenschaften für das Abonnement abgeschlossen wird.

getSubscriptionWithResponse

public Mono> getSubscriptionWithResponse(String topicName, String subscriptionName)

Ruft Informationen zum Abonnement zusammen mit seiner HTTP-Antwort ab.

Parameters:

topicName - Name des Themas, das dem Abonnement zugeordnet ist.
subscriptionName - Name des Abonnements, zu dem Informationen abgerufen werden sollen.

Returns:

Ein Mono,der mit Informationen zum Abonnement und der zugehörigen HTTP-Antwort abgeschlossen wird.

getTopic

public Mono getTopic(String topicName)

Ruft Informationen zum Thema ab.

Parameters:

topicName - Name des Themas, zu dem Informationen abgerufen werden sollen.

Returns:

Ein Mono,der mit Informationen zum Thema ergänzt wird.

getTopicExists

public Mono getTopicExists(String topicName)

Ruft ab, ob ein Thema mit topicName im Service Bus-Namespace vorhanden ist.

Parameters:

topicName - Name des Themas.

Returns:

Ein Mono-Wert, der abgeschlossen ist und angibt, ob das Thema vorhanden ist.

getTopicExistsWithResponse

public Mono> getTopicExistsWithResponse(String topicName)

Ruft ab, ob ein Thema mit topicName im Service Bus-Namespace vorhanden ist.

Parameters:

topicName - Name des Themas.

Returns:

Ein Mono-Wert, der abgeschlossen wird, der angibt, ob das Thema zusammen mit seiner HTTP-Antwort vorhanden ist.

getTopicRuntimeProperties

public Mono getTopicRuntimeProperties(String topicName)

Ruft Laufzeiteigenschaften zum Thema ab.

Parameters:

topicName - Name des Themas, zu dem Informationen abgerufen werden sollen.

Returns:

Ein Mono-Element, das mit Laufzeiteigenschaften zum Thema abgeschlossen wird.

getTopicRuntimePropertiesWithResponse

public Mono> getTopicRuntimePropertiesWithResponse(String topicName)

Ruft Laufzeiteigenschaften zum Thema mit seiner HTTP-Antwort ab.

Parameters:

topicName - Name des Themas, zu dem Informationen abgerufen werden sollen.

Returns:

Ein Mono-Element, das mit Laufzeiteigenschaften zum Thema und der zugehörigen HTTP-Antwort abgeschlossen wird.

getTopicWithResponse

public Mono> getTopicWithResponse(String topicName)

Ruft Informationen zum Thema zusammen mit der HTTP-Antwort ab.

Parameters:

topicName - Name des Themas, zu dem Informationen abgerufen werden sollen.

Returns:

Ein Mono,der mit Informationen zum Thema und der zugehörigen HTTP-Antwort ergänzt wird.

listQueues

public PagedFlux listQueues()

Ruft alle Warteschlangen im Service Bus-Namespace ab.

Returns:

Ein Flux von QueueProperties im Service Bus-Namespace.

listRules

public PagedFlux listRules(String topicName, String subscriptionName)

Ruft alle Regeln für ein Thema und ein Abonnement ab.

Parameters:

topicName - Der Themenname, unter dem alle Regeln abgerufen werden müssen.
subscriptionName - Der Name des Abonnements, für das alle Regeln abgerufen werden müssen.

Returns:

Ein Fluss von RuleProperties für und topicNamesubscriptionName.

listSubscriptions

public PagedFlux listSubscriptions(String topicName)

Ruft alle Abonnements für ein Thema ab.

Parameters:

topicName - Der Themenname, unter dem alle Abonnements abgerufen werden müssen.

Returns:

Ein Flux von SubscriptionProperties für .topicName

listTopics

public PagedFlux listTopics()

Ruft alle Themen im Service Bus-Namespace ab.

Returns:

Ein Flux von TopicProperties im Service Bus-Namespace.

updateQueue

public Mono updateQueue(QueueProperties queue)

Updates eine Warteschlange mit dem angegebenen QueueProperties. Die QueueProperties muss vollständig aufgefüllt werden, da alle Eigenschaften ersetzt werden. Wenn eine Eigenschaft nicht festgelegt ist, wird der Standardwert des Diensts verwendet. Der vorgeschlagene Flow lautet:

  1. getQueue(String queueName)
  2. Aktualisieren der erforderliche Elemente.
  3. Übergeben Sie die aktualisierte Beschreibung an diese Methode.

Es gibt eine Teilmenge der Eigenschaften, die aktualisiert werden können. Weitere Informationen finden Sie unter den links unten. Sie lauten wie folgt:

Parameters:

queue - Informationen zur zu aktualisierenden Warteschlange. Sie müssen alle Eigenschaftswerte angeben, die in der aktualisierten Entität gewünscht sind. Alle nicht angegebenen Werte werden auf die Standardwerte des Diensts festgelegt.

Returns:

Ein Mono,der mit der aktualisierten Warteschlange abgeschlossen wird.

updateQueueWithResponse

public Mono> updateQueueWithResponse(QueueProperties queue)

Updates eine Warteschlange mit dem angegebenen QueueProperties. Die QueueProperties muss vollständig aufgefüllt werden, da alle Eigenschaften ersetzt werden. Wenn eine Eigenschaft nicht festgelegt ist, wird der Standardwert des Diensts verwendet. Der vorgeschlagene Flow lautet:

  1. getQueue(String queueName)
  2. Aktualisieren der erforderliche Elemente.
  3. Übergeben Sie die aktualisierte Beschreibung an diese Methode.

Es gibt eine Teilmenge der Eigenschaften, die aktualisiert werden können. Weitere Informationen finden Sie unter den links unten. Sie lauten wie folgt:

Parameters:

queue - Informationen zur zu aktualisierenden Warteschlange. Sie müssen alle Eigenschaftswerte angeben, die in der aktualisierten Entität gewünscht sind. Alle nicht angegebenen Werte werden auf die Standardwerte des Diensts festgelegt.

Returns:

Ein Mono-Objekt, das die aktualisierte Warteschlange zusätzlich zur HTTP-Antwort zurückgibt.

updateRule

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

Updates eine Regel mit dem angegebenen RuleProperties. Muss RuleProperties vollständig aufgefüllt werden, wenn alle Eigenschaften ersetzt werden. Wenn eine Eigenschaft nicht festgelegt ist, wird der Standardwert des Diensts verwendet. Der vorgeschlagene Flow lautet:

  1. getRule(String topicName, String subscriptionName, String ruleName)
  2. Aktualisieren der erforderliche Elemente.
  3. Übergeben Sie die aktualisierte Beschreibung an diese Methode.

Parameters:

topicName - Der Themenname, unter dem die Regel aktualisiert wird.
subscriptionName - Der Name des Abonnements, für das die Regel aktualisiert wird.
rule - Informationen zur zu aktualisierenden Regel. Sie müssen alle Eigenschaftswerte angeben, die in der aktualisierten Entität gewünscht sind. Alle nicht angegebenen Werte werden auf die Standardwerte des Diensts festgelegt.

Returns:

Ein Mono-Objekt, das die aktualisierte Regel zurückgibt.

updateRuleWithResponse

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

Updates eine Regel mit dem angegebenen RuleProperties. Muss RuleProperties vollständig aufgefüllt werden, wenn alle Eigenschaften ersetzt werden. Wenn eine Eigenschaft nicht festgelegt ist, wird der Standardwert des Diensts verwendet. Der vorgeschlagene Flow lautet:

  1. getRule(String topicName, String subscriptionName, String ruleName)
  2. Aktualisieren der erforderliche Elemente.
  3. Übergeben Sie die aktualisierte Beschreibung an diese Methode.

Parameters:

topicName - Der Themenname, unter dem die Regel aktualisiert wird.
subscriptionName - Der Name des Abonnements, für das die Regel aktualisiert wird.
rule - Informationen zur zu aktualisierenden Regel. Sie müssen alle Eigenschaftswerte angeben, die in der aktualisierten Entität gewünscht sind. Alle nicht angegebenen Werte werden auf die Standardwerte des Diensts festgelegt.

Returns:

Ein Mono-Wert, der die aktualisierte Regel zusätzlich zur HTTP-Antwort zurückgibt.

updateSubscription

public Mono updateSubscription(SubscriptionProperties subscription)

Updates ein Abonnement mit dem angegebenen SubscriptionProperties. Die SubscriptionProperties muss vollständig aufgefüllt werden, da alle Eigenschaften ersetzt werden. Wenn eine Eigenschaft nicht festgelegt ist, wird der Standardwert des Diensts verwendet. Der vorgeschlagene Flow lautet:

  1. getSubscription(String topicName, String subscriptionName)
  2. Aktualisieren der erforderliche Elemente.
  3. Übergeben Sie die aktualisierte Beschreibung an diese Methode.

Es gibt eine Teilmenge der Eigenschaften, die aktualisiert werden können. Weitere Informationen finden Sie unter den links unten. Sie lauten wie folgt:

Parameters:

subscription - Informationen zum zu aktualisierenden Abonnement. Sie müssen alle Eigenschaftswerte angeben, die in der aktualisierten Entität gewünscht sind. Alle nicht angegebenen Werte werden auf die Standardwerte des Diensts festgelegt.

Returns:

Ein Mono-Objekt, das das aktualisierte Abonnement zurückgibt.

updateSubscriptionWithResponse

public Mono> updateSubscriptionWithResponse(SubscriptionProperties subscription)

Updates ein Abonnement mit dem angegebenen SubscriptionProperties. Die SubscriptionProperties muss vollständig aufgefüllt werden, da alle Eigenschaften ersetzt werden. Wenn eine Eigenschaft nicht festgelegt ist, wird der Standardwert des Diensts verwendet. Der vorgeschlagene Flow lautet:

  1. getSubscription(String topicName, String subscriptionName)
  2. Aktualisieren der erforderliche Elemente.
  3. Übergeben Sie die aktualisierte Beschreibung an diese Methode.

Es gibt eine Teilmenge der Eigenschaften, die aktualisiert werden können. Weitere Informationen finden Sie unter den links unten. Sie lauten wie folgt:

Parameters:

subscription - Informationen zum zu aktualisierenden Abonnement. Sie müssen alle Eigenschaftswerte angeben, die in der aktualisierten Entität gewünscht sind. Alle nicht angegebenen Werte werden auf die Standardwerte des Diensts festgelegt.

Returns:

Ein Mono-Objekt, das das aktualisierte Abonnement zusätzlich zur HTTP-Antwort zurückgibt.

updateTopic

public Mono updateTopic(TopicProperties topic)

Updates ein Thema mit dem angegebenen TopicProperties. Die TopicProperties muss vollständig aufgefüllt werden, da alle Eigenschaften ersetzt werden. Wenn eine Eigenschaft nicht festgelegt ist, wird der Standardwert des Diensts verwendet. Der vorgeschlagene Flow lautet:

  1. getTopic(String topicName)
  2. Aktualisieren der erforderliche Elemente.
  3. Übergeben Sie die aktualisierte Beschreibung an diese Methode.

Es gibt eine Teilmenge der Eigenschaften, die aktualisiert werden können. Weitere Informationen finden Sie unter den links unten. Sie lauten wie folgt:

Parameters:

topic - Informationen zum zu aktualisierenden Thema. Sie müssen alle Eigenschaftswerte angeben, die in der aktualisierten Entität gewünscht sind. Alle nicht angegebenen Werte werden auf die Standardwerte des Diensts festgelegt.

Returns:

Ein Mono,der mit dem aktualisierten Thema abgeschlossen wird.

updateTopicWithResponse

public Mono> updateTopicWithResponse(TopicProperties topic)

Updates ein Thema mit dem angegebenen TopicProperties. Die TopicProperties muss vollständig aufgefüllt werden, da alle Eigenschaften ersetzt werden. Wenn eine Eigenschaft nicht festgelegt ist, wird der Standardwert des Diensts verwendet. Der vorgeschlagene Flow lautet:

  1. getTopic(String topicName)
  2. Aktualisieren der erforderliche Elemente.
  3. Übergeben Sie die aktualisierte Beschreibung an diese Methode.

Es gibt eine Teilmenge der Eigenschaften, die aktualisiert werden können. Weitere Informationen finden Sie unter den links unten. Sie lauten wie folgt:

Parameters:

topic - Informationen zum zu aktualisierenden Thema. Sie müssen alle Eigenschaftswerte angeben, die in der aktualisierten Entität gewünscht sind. Alle nicht angegebenen Werte werden auf die Standardwerte des Diensts festgelegt.

Returns:

Ein Mono,der mit dem aktualisierten Thema und der zugehörigen HTTP-Antwort abgeschlossen wird.

Gilt für: