ServiceBusClientBuilder.ServiceBusReceiverClientBuilder Classe

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.