ServiceBusAdministrationClient Classe
- java.
lang. Object - com.
azure. messaging. servicebus. administration. ServiceBusAdministrationClient
- com.
public final class ServiceBusAdministrationClient
Um cliente síncrono para gerenciar um namespace do Barramento de Serviço. Instanciado por meio de ServiceBusAdministrationClientBuilder.
Exemplo: criar o cliente assíncrono
O exemplo de código a seguir demonstra a criação do cliente de administração assíncrona. A credencial usada no exemplo a seguir é DefaultAzureCredential
para autenticação. É apropriado para a maioria dos cenários, incluindo ambientes locais de desenvolvimento e produção. Além disso, recomendamos usar a identidade gerenciada para autenticação em ambientes de produção. Você pode encontrar mais informações sobre diferentes maneiras de autenticação e seus tipos de credencial correspondentes na documentação da Identidade do Azure.
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();
Exemplo: Criar uma fila
O exemplo a seguir cria uma fila com valores padrão. Os valores padrão são listados em CreateQueueOptions().
QueueProperties queue = client.createQueue("my-new-queue");
System.out.printf("Queue created. Name: %s. Lock Duration: %s.%n",
queue.getName(), queue.getLockDuration());
Exemplo: Editar uma assinatura existente
O exemplo de código a seguir demonstra a atualização de uma assinatura existente. Os usuários devem buscar as propriedades da assinatura, modificar as propriedades e, em seguida, passar o objeto para atualizar o 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());
Exemplo: listar todas as filas
O exemplo de código a seguir lista todas as filas no namespace do Barramento de Serviço.
client.listQueues().forEach(queue -> {
System.out.printf("Queue [%s]. Lock Duration: %s.%n",
queue.getName(), queue.getLockDuration());
});
Exemplo: Excluir fila
O exemplo de código abaixo demonstra a exclusão de uma fila existente.
try {
client.deleteQueue("my-existing-queue");
} catch (AzureException exception) {
System.err.println("Exception occurred deleting queue: " + exception);
}
Resumo do método
Métodos herdados de java.lang.Object
Detalhes do método
createQueue
public QueueProperties createQueue(String queueName)
Cria uma fila com o nome fornecido.
Parameters:
Returns:
createQueue
public QueueProperties createQueue(String queueName, CreateQueueOptions queueOptions)
Cria uma fila com o CreateQueueOptions.
Parameters:
Returns:
createQueueWithResponse
public Response
Cria uma fila e retorna a fila criada além da resposta HTTP.
Parameters:
Returns:
createRule
public RuleProperties createRule(String topicName, String subscriptionName, String ruleName)
Cria uma regra sob o tópico e a assinatura especificados
Parameters:
Returns:
createRule
public RuleProperties createRule(String topicName, String ruleName, String subscriptionName, CreateRuleOptions ruleOptions)
Cria uma regra com o CreateRuleOptions.
Parameters:
Returns:
createRuleWithResponse
public Response
Cria uma regra e retorna a regra criada além da resposta HTTP.
Parameters:
Returns:
createSubscription
public SubscriptionProperties createSubscription(String topicName, String subscriptionName)
Cria uma assinatura com os nomes de tópico e assinatura fornecidos.
Parameters:
Returns:
createSubscription
public SubscriptionProperties createSubscription(String topicName, String subscriptionName, CreateSubscriptionOptions subscriptionOptions)
Cria uma assinatura com o CreateSubscriptionOptions.
Parameters:
Returns:
createSubscription
public SubscriptionProperties createSubscription(String topicName, String subscriptionName, String ruleName, CreateSubscriptionOptions subscriptionOptions, CreateRuleOptions ruleOptions)
Cria uma assinatura com a regra padrão usando o CreateSubscriptionOptions e CreateRuleOptionso .
Parameters:
Returns:
createSubscriptionWithResponse
public Response
Cria uma assinatura e retorna a assinatura criada além da resposta HTTP.
Parameters:
Returns:
createSubscriptionWithResponse
public Response
Cria uma assinatura com a regra padrão configurada e retorna a assinatura criada além da resposta HTTP.
Parameters:
Returns:
createTopic
public TopicProperties createTopic(String topicName)
Cria um tópico com o nome fornecido.
Parameters:
Returns:
createTopic
public TopicProperties createTopic(String topicName, CreateTopicOptions topicOptions)
Cria um tópico com o CreateTopicOptions.
Parameters:
Returns:
createTopicWithResponse
public Response
Cria um tópico e retorna o tópico criado além da resposta HTTP.
Parameters:
Returns:
deleteQueue
public void deleteQueue(String queueName)
Exclui uma fila da correspondência queueName
.
Parameters:
deleteQueueWithResponse
public Response
Exclui uma fila da correspondência queueName
e retorna a resposta HTTP.
Parameters:
Returns:
deleteRule
public void deleteRule(String topicName, String subscriptionName, String ruleName)
Exclui uma regra da correspondência ruleName
.
Parameters:
deleteRuleWithResponse
public Response
Exclui uma regra da correspondência ruleName
e retorna a resposta HTTP.
Parameters:
Returns:
deleteSubscription
public void deleteSubscription(String topicName, String subscriptionName)
Exclui uma assinatura que corresponde ao subscriptionName
no tópico topicName
.
Parameters:
deleteSubscriptionWithResponse
public Response
Exclui uma assinatura da correspondência subscriptionName
e retorna a resposta HTTP.
Parameters:
Returns:
deleteTopic
public void deleteTopic(String topicName)
Exclui um tópico do correspondente topicName
.
Parameters:
deleteTopicWithResponse
public Response
Exclui um tópico da correspondência topicName
e retorna a resposta HTTP.
Parameters:
Returns:
getNamespaceProperties
public NamespaceProperties getNamespaceProperties()
Obtém informações sobre o namespace do Barramento de Serviço.
Returns:
getNamespacePropertiesWithResponse
public Response
Obtém informações sobre o namespace do Barramento de Serviço junto com sua resposta HTTP.
Parameters:
Returns:
getQueue
public QueueProperties getQueue(String queueName)
Obtém informações sobre a fila.
Parameters:
Returns:
getQueueExists
public boolean getQueueExists(String queueName)
Obtém se existe uma fila com queueName
no namespace do Barramento de Serviço.
Parameters:
Returns:
true
se a fila existir; caso contrário false
, .getQueueExistsWithResponse
public Response
Obtém se existe uma fila com queueName
no namespace do Barramento de Serviço.
Parameters:
Returns:
true
se a fila existir; caso contrário false
, .getQueueRuntimeProperties
public QueueRuntimeProperties getQueueRuntimeProperties(String queueName)
Obtém propriedades de runtime sobre a fila.
Parameters:
Returns:
getQueueRuntimePropertiesWithResponse
public Response
Obtém propriedades de runtime sobre a fila junto com sua resposta HTTP.
Parameters:
Returns:
getQueueWithResponse
public Response
Obtém informações sobre a fila junto com sua resposta HTTP.
Parameters:
Returns:
getRule
public RuleProperties getRule(String topicName, String subscriptionName, String ruleName)
Obtém uma regra do namespace de serviço. Somente os tipos de dados a seguir são desserializados nos parâmetros Filters e Action – string, int, long, boolean, double e OffsetDateTime. Outros tipos de dados retornariam seu valor de cadeia de caracteres.
Parameters:
Returns:
getRuleWithResponse
public Response
Obtém uma regra do namespace de serviço. Somente os tipos de dados a seguir são desserializados nos parâmetros Filters e Action – string, int, long, bool, double e OffsetDateTime. Outros tipos de dados retornariam seu valor de cadeia de caracteres.
Parameters:
Returns:
getSubscription
public SubscriptionProperties getSubscription(String topicName, String subscriptionName)
Obtém informações sobre a fila.
Parameters:
Returns:
getSubscriptionExists
public boolean getSubscriptionExists(String topicName, String subscriptionName)
Obtém se existe uma assinatura dentro de um tópico.
Parameters:
Returns:
true
se a assinatura existir.getSubscriptionExistsWithResponse
public Response
Obtém se existe uma assinatura dentro de um tópico.
Parameters:
Returns:
true
se a assinatura existir; caso contrário false
, .getSubscriptionRuntimeProperties
public SubscriptionRuntimeProperties getSubscriptionRuntimeProperties(String topicName, String subscriptionName)
Obtém propriedades de runtime sobre a assinatura.
Parameters:
Returns:
getSubscriptionRuntimePropertiesWithResponse
public Response
Obtém propriedades de runtime sobre a assinatura.
Parameters:
Returns:
getSubscriptionWithResponse
public Response
Obtém informações sobre a assinatura junto com sua resposta HTTP.
Parameters:
Returns:
getTopic
public TopicProperties getTopic(String topicName)
Obtém informações sobre o tópico.
Parameters:
Returns:
getTopicExists
public boolean getTopicExists(String topicName)
Obtém se um tópico com topicName
existe no namespace do Barramento de Serviço.
Parameters:
Returns:
true
se o tópico existir.getTopicExistsWithResponse
public Response
Obtém se um tópico com topicName
existe no namespace do Barramento de Serviço.
Parameters:
Returns:
true
se o tópico existir; caso contrário false
, .getTopicRuntimeProperties
public TopicRuntimeProperties getTopicRuntimeProperties(String topicName)
Obtém propriedades de runtime sobre o tópico.
Parameters:
Returns:
getTopicRuntimePropertiesWithResponse
public Response
Obtém propriedades de runtime sobre o tópico com sua resposta HTTP.
Parameters:
Returns:
getTopicWithResponse
public Response
Obtém informações sobre o tópico junto com sua resposta HTTP.
Parameters:
Returns:
listQueues
public PagedIterable
Busca todas as filas no namespace do Barramento de Serviço.
Returns:
listQueues
public PagedIterable
Busca todas as filas no namespace do Barramento de Serviço.
Parameters:
Returns:
listRules
public PagedIterable
Busca todas as regras para um tópico e uma assinatura.
Parameters:
Returns:
listRules
public PagedIterable
Busca todas as regras para um tópico e uma assinatura.
Parameters:
Returns:
listSubscriptions
public PagedIterable
Busca todas as assinaturas para um tópico.
Parameters:
Returns:
topicName
.listSubscriptions
public PagedIterable
Busca todas as assinaturas para um tópico.
Parameters:
Returns:
topicName
.listTopics
public PagedIterable
Busca todos os tópicos no namespace do Barramento de Serviço.
Returns:
listTopics
public PagedIterable
Busca todos os tópicos no namespace do Barramento de Serviço.
Parameters:
Returns:
updateQueue
public QueueProperties updateQueue(QueueProperties queue)
Atualizações uma fila com o fornecidoQueueProperties. O QueueProperties deve ser totalmente preenchido, pois todas as propriedades são substituídas. Se uma propriedade não estiver definida, o valor padrão do serviço será usado. O fluxo sugerido é:
- getQueue(String queueName)
- Atualizar os elementos necessários.
- Passe a descrição atualizada para esse método.
Há um subconjunto de propriedades que podem ser atualizadas. Mais informações podem ser encontradas nos links abaixo. Eles são:
- setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
- setLockDuration(Duration lockDuration)
- setDuplicateDetectionHistoryTimeWindow(Duration duplicateDetectionHistoryTimeWindow)
- setMaxDeliveryCount(Integer maxDeliveryCount)
Parameters:
Returns:
updateQueueWithResponse
public Response
Atualizações uma fila com o fornecidoQueueProperties. O QueueProperties deve ser totalmente preenchido, pois todas as propriedades são substituídas. Se uma propriedade não estiver definida, o valor padrão do serviço será usado. O fluxo sugerido é:
- getQueue(String queueName)
- Atualizar os elementos necessários.
- Passe a descrição atualizada para esse método.
Há um subconjunto de propriedades que podem ser atualizadas. Mais informações podem ser encontradas nos links abaixo. Eles são:
- setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
- setLockDuration(Duration lockDuration)
- setDuplicateDetectionHistoryTimeWindow(Duration duplicateDetectionHistoryTimeWindow)
- setMaxDeliveryCount(Integer maxDeliveryCount)
Parameters:
Returns:
updateRule
public RuleProperties updateRule(String topicName, String subscriptionName, RuleProperties rule)
Atualizações uma regra com o fornecidoRuleProperties. O RuleProperties deve ser totalmente preenchido, pois todas as propriedades são substituídas. Se uma propriedade não estiver definida, o valor padrão do serviço será usado. O fluxo sugerido é:
- getRule(String topicName, String subscriptionName, String ruleName)
- Atualizar os elementos necessários.
- Passe a descrição atualizada para esse método.
Parameters:
Returns:
updateRuleWithResponse
public Response
Atualizações uma regra com o fornecidoRuleProperties. O RuleProperties deve ser totalmente preenchido, pois todas as propriedades são substituídas. Se uma propriedade não estiver definida, o valor padrão do serviço será usado. O fluxo sugerido é:
- getRule(String topicName, String subscriptionName, String ruleName)
- Atualizar os elementos necessários.
- Passe a descrição atualizada para esse método.
Parameters:
Returns:
updateSubscription
public SubscriptionProperties updateSubscription(SubscriptionProperties subscription)
Atualizações uma assinatura com o fornecidoSubscriptionProperties. O SubscriptionProperties deve ser totalmente preenchido, pois todas as propriedades são substituídas. Se uma propriedade não estiver definida, o valor padrão do serviço será usado. O fluxo sugerido é:
- getSubscription(String topicName, String subscriptionName)
- Atualizar os elementos necessários.
- Passe a descrição atualizada para esse método.
Há um subconjunto de propriedades que podem ser atualizadas. Mais informações podem ser encontradas nos links abaixo. Eles são:
- setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
- setLockDuration(Duration lockDuration)
- setMaxDeliveryCount(int maxDeliveryCount)
Parameters:
Returns:
updateSubscriptionWithResponse
public Response
Atualizações uma assinatura com o fornecidoSubscriptionProperties. O SubscriptionProperties deve ser totalmente preenchido, pois todas as propriedades são substituídas. Se uma propriedade não estiver definida, o valor padrão do serviço será usado. O fluxo sugerido é:
- getSubscription(String topicName, String subscriptionName)
- Atualizar os elementos necessários.
- Passe a descrição atualizada para esse método.
Há um subconjunto de propriedades que podem ser atualizadas. Mais informações podem ser encontradas nos links abaixo. Eles são:
- setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
- setLockDuration(Duration lockDuration)
- setMaxDeliveryCount(int maxDeliveryCount)
Parameters:
Returns:
updateTopic
public TopicProperties updateTopic(TopicProperties topic)
Atualizações um tópico com o fornecidoTopicProperties. O TopicProperties deve ser totalmente preenchido, pois todas as propriedades são substituídas. Se uma propriedade não estiver definida, o valor padrão do serviço será usado. O fluxo sugerido é:
- getTopic(String topicName)
- Atualizar os elementos necessários.
- Passe a descrição atualizada para esse método.
Há um subconjunto de propriedades que podem ser atualizadas. Mais informações podem ser encontradas nos links abaixo. Eles são:
- setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
- setDuplicateDetectionHistoryTimeWindow(Duration duplicateDetectionHistoryTimeWindow)
Parameters:
Returns:
updateTopicWithResponse
public Response
Atualizações um tópico com o determinado TopicProperties. O TopicProperties deve ser totalmente preenchido à medida que todas as propriedades são substituídas. Se uma propriedade não for definida, o valor padrão do serviço será usado. O fluxo sugerido é:
- getTopic(String topicName)
- Atualizar os elementos necessários.
- Passe a descrição atualizada para esse método.
Há um subconjunto de propriedades que podem ser atualizadas. Mais informações podem ser encontradas nos links abaixo. Eles são:
- setDefaultMessageTimeToLive(Duration defaultMessageTimeToLive)
- setDuplicateDetectionHistoryTimeWindow(Duration duplicateDetectionHistoryTimeWindow)
Parameters:
Returns:
Aplica-se a
Azure SDK for Java