ServiceBusClientBuilder.ServiceBusReceiverClientBuilder 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.ServiceBusClientBuilder.ServiceBusReceiverClientBuilder

public final class ServiceBusClientBuilder.ServiceBusReceiverClientBuilder

Construtor para criar ServiceBusReceiverClient e ServiceBusReceiverAsyncClient consumir mensagens do Barramento de Serviço.

Resumo do método

Modificador e tipo Método e descrição
ServiceBusReceiverAsyncClient buildAsyncClient()

Cria um receptor assíncrono do Barramento de Serviço responsável pela leitura ServiceBusMessage de uma fila ou assinatura específica.
ServiceBusReceiverClient buildClient()

Cria um receptor síncrono do Barramento de Serviço responsável pela leitura ServiceBusMessage de uma fila ou assinatura específica.
ServiceBusReceiverClientBuilder disableAutoComplete()

Desabilita o preenchimento automático e o abandono automático das mensagens recebidas.
ServiceBusReceiverClientBuilder maxAutoLockRenewDuration(Duration maxAutoLockRenewDuration)

Define a quantidade de tempo para continuar renovando automaticamente o bloqueio.
ServiceBusReceiverClientBuilder prefetchCount(int prefetchCount)

Define a contagem de pré-busca do receptor.
ServiceBusReceiverClientBuilder queueName(String queueName)

Define o nome da fila para a qual criar um receptor.
ServiceBusReceiverClientBuilder receiveMode(ServiceBusReceiveMode receiveMode)

Define o modo de recebimento para o receptor.
ServiceBusReceiverClientBuilder subQueue(SubQueue subQueue)

Define o tipo do SubQueue ao qual se conectar.
ServiceBusReceiverClientBuilder subscriptionName(String subscriptionName)

Define o nome da assinatura no tópico a ser escutado.
ServiceBusReceiverClientBuilder topicName(String topicName)

Define o nome do tópico.

Métodos herdados de java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Detalhes do método

buildAsyncClient

public ServiceBusReceiverAsyncClient buildAsyncClient()

Cria um receptor assíncrono do Barramento de Serviço responsável pela leitura ServiceBusMessage de uma fila ou assinatura específica.

Returns:

Um novo ServiceBusReceiverAsyncClient que recebe mensagens de uma fila ou assinatura.

buildClient

public ServiceBusReceiverClient buildClient()

Cria um receptor síncrono do Barramento de Serviço responsável pela leitura ServiceBusMessage de uma fila ou assinatura específica.

Returns:

Um novo ServiceBusReceiverClient que recebe mensagens de uma fila ou assinatura.

disableAutoComplete

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder disableAutoComplete()

Desabilita o preenchimento automático e o abandono automático das mensagens recebidas. Por padrão, uma mensagem processada com êxito é complete(ServiceBusReceivedMessage message). Se ocorrer um erro quando a mensagem for processada, será abandon(ServiceBusReceivedMessage message).

Returns:

O objeto ServiceBusReceiverClientBuilder modificado.

maxAutoLockRenewDuration

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder maxAutoLockRenewDuration(Duration maxAutoLockRenewDuration)

Define a quantidade de tempo para continuar renovando automaticamente o bloqueio. Definir Duration#ZERO ou null desabilitar a renovação automática. Para RECEIVE_AND_DELETE o modo, a renovação automática está desabilitada.

Parameters:

maxAutoLockRenewDuration - a quantidade de tempo para continuar renovando automaticamente o bloqueio. Duration#ZERO ou null indica que a renovação automática está desabilitada.

Returns:

O objeto atualizado ServiceBusReceiverClientBuilder.

prefetchCount

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder prefetchCount(int prefetchCount)

Define a contagem de pré-busca do receptor. Para os PEEK_LOCK modos e RECEIVE_AND_DELETE , o valor padrão é 1. A pré-busca acelera o fluxo de mensagens com o objetivo de ter uma mensagem prontamente disponível para recuperação local quando e antes que o aplicativo solicite uma usando receiveMessages(). Definir um valor diferente de zero irá pré-buscar esse número de mensagens. Definir o valor como zero desativa a pré-busca.

Parameters:

prefetchCount - A contagem de pré-busca.

Returns:

O objeto ServiceBusReceiverClientBuilder modificado.

queueName

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder queueName(String queueName)

Define o nome da fila para a qual criar um receptor.

Parameters:

queueName - Nome da fila.

Returns:

O objeto ServiceBusReceiverClientBuilder modificado.

receiveMode

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder receiveMode(ServiceBusReceiveMode receiveMode)

Define o modo de recebimento para o receptor.

Parameters:

receiveMode - Modo para receber mensagens.

Returns:

O objeto ServiceBusReceiverClientBuilder modificado.

subQueue

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder subQueue(SubQueue subQueue)

Define o tipo do SubQueue ao qual se conectar.

Parameters:

subQueue - O tipo da sub fila.

Returns:

O objeto ServiceBusReceiverClientBuilder modificado.

subscriptionName

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder subscriptionName(String subscriptionName)

Define o nome da assinatura no tópico a ser escutado. topicName(String topicName) também deve ser definido.

Parameters:

subscriptionName - O nome da assinatura.

Returns:

O objeto ServiceBusReceiverClientBuilder modificado.

topicName

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder topicName(String topicName)

Define o nome do tópico. subscriptionName(String subscriptionName) também deve ser definido.

Parameters:

topicName - Nome do tópico.

Returns:

O objeto ServiceBusReceiverClientBuilder modificado.

Aplica-se a