ServiceBusAdministrationClient Clase
- java.
lang. Object - com.
azure. messaging. servicebus. administration. ServiceBusAdministrationClient
- com.
public final class ServiceBusAdministrationClient
Un cliente sincrónico para administrar un espacio de nombres de Service Bus. Se crean instancias a través de ServiceBusAdministrationClientBuilder.
Ejemplo: Creación del cliente asincrónico
En el ejemplo de código siguiente se muestra la creación del cliente de administración asincrónica. La credencial usada en el ejemplo siguiente es DefaultAzureCredential
para la autenticación. Es adecuado para la mayoría de los escenarios, incluidos los entornos de desarrollo y producción locales. Además, se recomienda usar la identidad administrada para la autenticación en entornos de producción. Puede encontrar más información sobre las distintas formas de autenticación y sus tipos de credenciales correspondientes en la documentación de Azure Identity.
HttpLogOptions logOptions = new HttpLogOptions()
.setLogLevel(HttpLogDetailLevel.HEADERS);
// DefaultAzureCredential creates a credential based on the environment it is executed in.
TokenCredential tokenCredential = new DefaultAzureCredentialBuilder().build();
// 'fullyQualifiedNamespace' will look similar to "{your-namespace}.servicebus.windows.net"
ServiceBusAdministrationClient client = new ServiceBusAdministrationClientBuilder()
.credential(fullyQualifiedNamespace, tokenCredential)
.httpLogOptions(logOptions)
.buildClient();
Ejemplo: Creación de una cola
En el ejemplo siguiente se crea una cola con valores predeterminados. Los valores predeterminados se muestran en CreateQueueOptions().
QueueProperties queue = client.createQueue("my-new-queue");
System.out.printf("Queue created. Name: %s. Lock Duration: %s.%n",
queue.getName(), queue.getLockDuration());
Ejemplo: Edición de una suscripción existente
En el ejemplo de código siguiente se muestra cómo actualizar una suscripción existente. Los usuarios deben capturar las propiedades de la suscripción, modificar las propiedades y, a continuación, pasar el objeto para actualizar el método.
// 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.
SubscriptionProperties subscription = client.getSubscription("my-topic", "my-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.
SubscriptionProperties updated = client.updateSubscription(subscription);
System.out.printf("Subscription updated. Name: %s. Delivery count: %s.%n",
updated.getSubscriptionName(), updated.getMaxDeliveryCount());
Ejemplo: Enumeración de todas las colas
En el ejemplo de código siguiente se enumeran todas las colas del espacio de nombres de Service Bus.
client.listQueues().forEach(queue -> {
System.out.printf("Queue [%s]. Lock Duration: %s.%n",
queue.getName(), queue.getLockDuration());
});
Ejemplo: Eliminar cola
En el ejemplo de código siguiente se muestra cómo eliminar una cola existente.
try {
client.deleteQueue("my-existing-queue");
} catch (AzureException exception) {
System.err.println("Exception occurred deleting queue: " + exception);
}
Resumen del método
Métodos heredados de java.lang.Object
Detalles del método
createQueue
public QueueProperties createQueue(String queueName)
Crea una cola con el nombre especificado.
Parameters:
Returns:
createQueue
public QueueProperties createQueue(String queueName, CreateQueueOptions queueOptions)
Crea una cola con .CreateQueueOptions
Parameters:
Returns:
createQueueWithResponse
public Response
Crea una cola y devuelve la cola creada además de la respuesta HTTP.
Parameters:
Returns:
createRule
public RuleProperties createRule(String topicName, String subscriptionName, String ruleName)
Crea una regla en el tema y la suscripción especificados.
Parameters:
Returns:
createRule
public RuleProperties createRule(String topicName, String ruleName, String subscriptionName, CreateRuleOptions ruleOptions)
Crea una regla con .CreateRuleOptions
Parameters:
Returns:
createRuleWithResponse
public Response
Crea una regla y devuelve la regla creada además de la respuesta HTTP.
Parameters:
Returns:
createSubscription
public SubscriptionProperties createSubscription(String topicName, String subscriptionName)
Crea una suscripción con los nombres de suscripción y el tema especificados.
Parameters:
Returns:
createSubscription
public SubscriptionProperties createSubscription(String topicName, String subscriptionName, CreateSubscriptionOptions subscriptionOptions)
Crea una suscripción con .CreateSubscriptionOptions
Parameters:
Returns:
createSubscription
public SubscriptionProperties createSubscription(String topicName, String subscriptionName, String ruleName, CreateSubscriptionOptions subscriptionOptions, CreateRuleOptions ruleOptions)
Crea una suscripción con una regla predeterminada mediante y CreateSubscriptionOptionsCreateRuleOptions.
Parameters:
Returns:
createSubscriptionWithResponse
public Response
Crea una suscripción y devuelve la suscripción creada además de la respuesta HTTP.
Parameters:
Returns:
createSubscriptionWithResponse
public Response
Crea una suscripción con una regla predeterminada configurada y devuelve la suscripción creada además de la respuesta HTTP.
Parameters:
Returns:
createTopic
public TopicProperties createTopic(String topicName)
Crea un tema con el nombre especificado.
Parameters:
Returns:
createTopic
public TopicProperties createTopic(String topicName, CreateTopicOptions topicOptions)
Crea un tema con CreateTopicOptions.
Parameters:
Returns:
createTopicWithResponse
public Response
Crea un tema y devuelve el tema creado además de la respuesta HTTP.
Parameters:
Returns:
deleteQueue
public void deleteQueue(String queueName)
Elimina una cola que coincide con queueName
.
Parameters:
deleteQueueWithResponse
public Response
Elimina una cola que coincide queueName
y devuelve la respuesta HTTP.
Parameters:
Returns:
deleteRule
public void deleteRule(String topicName, String subscriptionName, String ruleName)
Elimina una regla que coincide con ruleName
.
Parameters:
deleteRuleWithResponse
public Response
Elimina una regla que coincide ruleName
y devuelve la respuesta HTTP.
Parameters:
Returns:
deleteSubscription
public void deleteSubscription(String topicName, String subscriptionName)
Elimina una suscripción que coincide con en el subscriptionName
tema topicName
.
Parameters:
deleteSubscriptionWithResponse
public Response
Elimina una suscripción que coincide subscriptionName
y devuelve la respuesta HTTP.
Parameters:
Returns:
deleteTopic
public void deleteTopic(String topicName)
Elimina un tema que coincide con topicName
.
Parameters:
deleteTopicWithResponse
public Response
Elimina un tema que coincide topicName
y devuelve la respuesta HTTP.
Parameters:
Returns:
getNamespaceProperties
public NamespaceProperties getNamespaceProperties()
Obtiene información sobre el espacio de nombres de Service Bus.
Returns:
getNamespacePropertiesWithResponse
public Response
Obtiene información sobre el espacio de nombres de Service Bus junto con su respuesta HTTP.
Parameters:
Returns:
getQueue
public QueueProperties getQueue(String queueName)
Obtiene información sobre la cola.
Parameters:
Returns:
getQueueExists
public boolean getQueueExists(String queueName)
Obtiene si existe una cola con queueName
en el espacio de nombres de Service Bus.
Parameters:
Returns:
true
si la cola existe; de lo contrario false
, .getQueueExistsWithResponse
public Response
Obtiene si existe una cola con queueName
en el espacio de nombres de Service Bus.
Parameters:
Returns:
true
si la cola existe; de lo contrario false
, .getQueueRuntimeProperties
public QueueRuntimeProperties getQueueRuntimeProperties(String queueName)
Obtiene las propiedades en tiempo de ejecución sobre la cola.
Parameters:
Returns:
getQueueRuntimePropertiesWithResponse
public Response
Obtiene las propiedades en tiempo de ejecución de la cola junto con su respuesta HTTP.
Parameters:
Returns:
getQueueWithResponse
public Response
Obtiene información sobre la cola junto con su respuesta HTTP.
Parameters:
Returns:
getRule
public RuleProperties getRule(String topicName, String subscriptionName, String ruleName)
Obtiene una regla del espacio de nombres del servicio. Solo se deserializan los siguientes tipos de datos en los parámetros Filters y Action: string, int, long, boolean, double y OffsetDateTime. Otros tipos de datos devolverían su valor de cadena.
Parameters:
Returns:
getRuleWithResponse
public Response
Obtiene una regla del espacio de nombres del servicio. Solo se deserializan los siguientes tipos de datos en los parámetros Filters y Action: string, int, long, bool, double y OffsetDateTime. Otros tipos de datos devolverían su valor de cadena.
Parameters:
Returns:
getSubscription
public SubscriptionProperties getSubscription(String topicName, String subscriptionName)
Obtiene información sobre la cola.
Parameters:
Returns:
getSubscriptionExists
public boolean getSubscriptionExists(String topicName, String subscriptionName)
Obtiene si existe una suscripción dentro de un tema.
Parameters:
Returns:
true
si la suscripción existe.getSubscriptionExistsWithResponse
public Response
Obtiene si existe una suscripción dentro de un tema.
Parameters:
Returns:
true
si la suscripción existe; de lo contrario false
, .getSubscriptionRuntimeProperties
public SubscriptionRuntimeProperties getSubscriptionRuntimeProperties(String topicName, String subscriptionName)
Obtiene las propiedades en tiempo de ejecución sobre la suscripción.
Parameters:
Returns:
getSubscriptionRuntimePropertiesWithResponse
public Response
Obtiene las propiedades en tiempo de ejecución sobre la suscripción.
Parameters:
Returns:
getSubscriptionWithResponse
public Response
Obtiene información sobre la suscripción junto con su respuesta HTTP.
Parameters:
Returns:
getTopic
public TopicProperties getTopic(String topicName)
Obtiene información sobre el tema.
Parameters:
Returns:
getTopicExists
public boolean getTopicExists(String topicName)
Obtiene si existe un tema con topicName
en el espacio de nombres de Service Bus.
Parameters:
Returns:
true
si el tema existe.getTopicExistsWithResponse
public Response
Obtiene si existe un tema con topicName
en el espacio de nombres de Service Bus.
Parameters:
Returns:
true
si el tema existe; de lo contrario false
, .getTopicRuntimeProperties
public TopicRuntimeProperties getTopicRuntimeProperties(String topicName)
Obtiene propiedades en tiempo de ejecución sobre el tema.
Parameters:
Returns:
getTopicRuntimePropertiesWithResponse
public Response
Obtiene las propiedades en tiempo de ejecución sobre el tema con su respuesta HTTP.
Parameters:
Returns:
getTopicWithResponse
public Response
Obtiene información sobre el tema junto con su respuesta HTTP.
Parameters:
Returns:
listQueues
public PagedIterable
Captura todas las colas del espacio de nombres de Service Bus.
Returns:
listQueues
public PagedIterable
Captura todas las colas del espacio de nombres de Service Bus.
Parameters:
Returns:
listRules
public PagedIterable
Captura todas las reglas de un tema y una suscripción.
Parameters:
Returns:
listRules
public PagedIterable
Captura todas las reglas de un tema y una suscripción.
Parameters:
Returns:
listSubscriptions
public PagedIterable
Captura todas las suscripciones de un tema.
Parameters:
Returns:
topicName
listSubscriptions
public PagedIterable
Captura todas las suscripciones de un tema.
Parameters:
Returns:
topicName
listTopics
public PagedIterable
Captura todos los temas del espacio de nombres de Service Bus.
Returns:
listTopics
public PagedIterable
Captura todos los temas del espacio de nombres de Service Bus.
Parameters:
Returns:
updateQueue
public QueueProperties updateQueue(QueueProperties queue)
Novedades una cola con el especificadoQueueProperties. QueueProperties Debe rellenarse completamente, ya que se reemplazan todas las propiedades. Si no se establece una propiedad, se usa el valor predeterminado del servicio. El flujo sugerido es:
- getQueue(String queueName)
- Actualizar los elementos necesarios.
- Pase la descripción actualizada a este método.
Hay un subconjunto de propiedades que se pueden actualizar. Puede encontrar más información en los vínculos siguientes. Son las siguientes:
- setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
- setLockDuration(Duration lockDuration)
- setDuplicateDetectionHistoryTimeWindow(Duration duplicateDetectionHistoryTimeWindow)
- setMaxDeliveryCount(Integer maxDeliveryCount)
Parameters:
Returns:
updateQueueWithResponse
public Response
Novedades una cola con el especificadoQueueProperties. QueueProperties Debe rellenarse completamente, ya que se reemplazan todas las propiedades. Si no se establece una propiedad, se usa el valor predeterminado del servicio. El flujo sugerido es:
- getQueue(String queueName)
- Actualizar los elementos necesarios.
- Pase la descripción actualizada a este método.
Hay un subconjunto de propiedades que se pueden actualizar. Puede encontrar más información en los vínculos siguientes. Son las siguientes:
- setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
- setLockDuration(Duration lockDuration)
- setDuplicateDetectionHistoryTimeWindow(Duration duplicateDetectionHistoryTimeWindow)
- setMaxDeliveryCount(Integer maxDeliveryCount)
Parameters:
Returns:
updateRule
public RuleProperties updateRule(String topicName, String subscriptionName, RuleProperties rule)
Novedades una regla con el especificadoRuleProperties. RuleProperties Debe rellenarse completamente, ya que se reemplazan todas las propiedades. Si no se establece una propiedad, se usa el valor predeterminado del servicio. El flujo sugerido es:
- getRule(String topicName, String subscriptionName, String ruleName)
- Actualizar los elementos necesarios.
- Pase la descripción actualizada a este método.
Parameters:
Returns:
updateRuleWithResponse
public Response
Novedades una regla con el especificadoRuleProperties. RuleProperties Debe rellenarse completamente, ya que se reemplazan todas las propiedades. Si no se establece una propiedad, se usa el valor predeterminado del servicio. El flujo sugerido es:
- getRule(String topicName, String subscriptionName, String ruleName)
- Actualizar los elementos necesarios.
- Pase la descripción actualizada a este método.
Parameters:
Returns:
updateSubscription
public SubscriptionProperties updateSubscription(SubscriptionProperties subscription)
Novedades una suscripción con el especificadoSubscriptionProperties. SubscriptionProperties Debe rellenarse completamente, ya que se reemplazan todas las propiedades. Si no se establece una propiedad, se usa el valor predeterminado del servicio. El flujo sugerido es:
- getSubscription(String topicName, String subscriptionName)
- Actualizar los elementos necesarios.
- Pase la descripción actualizada a este método.
Hay un subconjunto de propiedades que se pueden actualizar. Puede encontrar más información en los vínculos siguientes. Son las siguientes:
- setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
- setLockDuration(Duration lockDuration)
- setMaxDeliveryCount(int maxDeliveryCount)
Parameters:
Returns:
updateSubscriptionWithResponse
public Response
Novedades una suscripción con el especificadoSubscriptionProperties. SubscriptionProperties Debe rellenarse completamente, ya que se reemplazan todas las propiedades. Si no se establece una propiedad, se usa el valor predeterminado del servicio. El flujo sugerido es:
- getSubscription(String topicName, String subscriptionName)
- Actualizar los elementos necesarios.
- Pase la descripción actualizada a este método.
Hay un subconjunto de propiedades que se pueden actualizar. Puede encontrar más información en los vínculos siguientes. Son las siguientes:
- setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
- setLockDuration(Duration lockDuration)
- setMaxDeliveryCount(int maxDeliveryCount)
Parameters:
Returns:
updateTopic
public TopicProperties updateTopic(TopicProperties topic)
Novedades un tema con el especificadoTopicProperties. TopicProperties Debe rellenarse completamente, ya que se reemplazan todas las propiedades. Si no se establece una propiedad, se usa el valor predeterminado del servicio. El flujo sugerido es:
- getTopic(String topicName)
- Actualizar los elementos necesarios.
- Pase la descripción actualizada a este método.
Hay un subconjunto de propiedades que se pueden actualizar. Puede encontrar más información en los vínculos siguientes. Son las siguientes:
- setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
- setDuplicateDetectionHistoryTimeWindow(Duration duplicateDetectionHistoryTimeWindow)
Parameters:
Returns:
updateTopicWithResponse
public Response
Novedades un tema con el especificadoTopicProperties. debe TopicProperties rellenarse completamente, ya que se reemplazan todas las propiedades. Si no se establece una propiedad, se usa el valor predeterminado del servicio. El flujo sugerido es:
- getTopic(String topicName)
- Actualizar los elementos necesarios.
- Pase la descripción actualizada a este método.
Hay un subconjunto de propiedades que se pueden actualizar. Puede encontrar más información en los vínculos siguientes. Son las siguientes:
- setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
- setDuplicateDetectionHistoryTimeWindow(Duration duplicateDetectionHistoryTimeWindow)
Parameters:
Returns:
Se aplica a
Azure SDK for Java