Partilhar via

ServiceBusRuleManagerAsyncClient Classe

  • Referência
Pacote:
com.azure.messaging.servicebus
Artefato Maven:
com.azure:azure-messaging-servicebus:7.17.0
  • java.lang.Object
    • com.azure.messaging.servicebus.ServiceBusRuleManagerAsyncClient

Implementações

AutoCloseable

public class ServiceBusRuleManagerAsyncClient
implements AutoCloseable

Um gerenciador de regras assíncrono responsável por gerenciar regras para uma assinatura de tópico específica. O gerenciador de regras requer apenas Escutar declarações, enquanto o ServiceBusAdministrationAsyncClient requer Gerenciar declarações.

Criar uma instância do gerenciador de regras

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

Criar uma regra para uma assinatura do Barramento de Serviço

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

Buscar todas as regras.

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

Excluir uma regra.

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

Resumo do método

Modificador e tipo Método e descrição
void close()

Descarta o ServiceBusRuleManagerAsyncClient.
Mono<Void> createRule(String ruleName, CreateRuleOptions options)

Cria uma regra para a assinatura atual para filtrar as mensagens que chegam do tópico à assinatura.
Mono<Void> deleteRule(String ruleName)

Remove a regra na assinatura identificada por ruleName.
String getEntityPath()

Obtém o nome do recurso do Barramento de Serviço.
String getFullyQualifiedNamespace()

Obtém o namespace totalmente qualificado.
Flux<RuleProperties> listRules()

Busca todas as regras associadas ao tópico e à assinatura.

Métodos herdados de java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Detalhes do método

close

public void close()

Descarta o ServiceBusRuleManagerAsyncClient. Se o cliente tiver uma conexão dedicada, a conexão subjacente também será fechada.

createRule

public Mono createRule(String ruleName, CreateRuleOptions options)

Cria uma regra para a assinatura atual para filtrar as mensagens que chegam do tópico à assinatura.

Parameters:

ruleName - Nome da regra.
options - As opções para a regra a ser adicionada.

Returns:

Um Mono que é concluído quando a regra é criada.

deleteRule

public Mono deleteRule(String ruleName)

Remove a regra na assinatura identificada por ruleName.

Parameters:

ruleName - Nome da regra a ser excluída.

Returns:

Um Mono que é concluído quando a regra é excluída.

getEntityPath

public String getEntityPath()

Obtém o nome do recurso do Barramento de Serviço.

Returns:

O nome do recurso do Barramento de Serviço.

getFullyQualifiedNamespace

public String getFullyQualifiedNamespace()

Obtém o namespace totalmente qualificado.

Returns:

O namespace totalmente qualificado.

listRules

public Flux listRules()

Busca todas as regras associadas ao tópico e à assinatura.

Returns:

Uma lista de regras associadas ao tópico e à assinatura.

Aplica-se a