ServiceBusRuleManagerAsyncClient Clase

Paquete:

com.azure.messaging.servicebus

Artefacto Maven:

com.azure:azure-messaging-servicebus:7.17.0

• java.lang.Object
• • com.azure.messaging.servicebus.ServiceBusRuleManagerAsyncClient

Implementaciones

Autocloseable

public class ServiceBusRuleManagerAsyncClient
implements AutoCloseable

Un administrador de reglas asincrónico responsable de administrar reglas para una suscripción de tema específica. El administrador de reglas solo requiere notificaciones de escucha, mientras que requiere ServiceBusAdministrationAsyncClient administrar notificaciones.

Creación de una instancia del administrador de reglas

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

Creación de una regla en una suscripción de 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();

Captura todas las reglas.

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

Elimine una regla.

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

Resumen del método

Modificador y tipo	Método y descripción
void	close() Elimina de ServiceBusRuleManagerAsyncClient.
Mono<Void>	createRule(String ruleName, CreateRuleOptions options) Crea una regla en la suscripción actual para filtrar los mensajes que llegan desde el tema a la suscripción.
Mono<Void>	deleteRule(String ruleName) Quita la regla de la suscripción identificada por ruleName.
String	getEntityPath() Obtiene el nombre del recurso de Service Bus.
String	getFullyQualifiedNamespace() Obtiene el espacio de nombres completo.
Flux<RuleProperties>	listRules() Captura todas las reglas asociadas al tema y a la suscripción.

Métodos heredados de java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Detalles del método

close

public void close()

Elimina de ServiceBusRuleManagerAsyncClient. Si el cliente tiene una conexión dedicada, también se cierra la conexión subyacente.

createRule

public Mono createRule(String ruleName, CreateRuleOptions options)

Crea una regla en la suscripción actual para filtrar los mensajes que llegan desde el tema a la suscripción.

Parameters:

ruleName - Nombre de la regla.

options - Opciones de la regla que se va a agregar.

Returns:

Mono que se completa cuando se crea la regla.

deleteRule

public Mono deleteRule(String ruleName)

Quita la regla de la suscripción identificada por ruleName.

Parameters:

ruleName - Nombre de la regla que se va a eliminar.

Returns:

Mono que se completa cuando se elimina la regla.

getEntityPath

public String getEntityPath()

Obtiene el nombre del recurso de Service Bus.

Returns:

Nombre del recurso de Service Bus.

getFullyQualifiedNamespace

public String getFullyQualifiedNamespace()

Obtiene el espacio de nombres completo.

Returns:

Espacio de nombres completo.

listRules

public Flux listRules()

Captura todas las reglas asociadas al tema y a la suscripción.

Returns:

Lista de reglas asociadas al tema y a la suscripción.