Compartir a través de


ServiceBusClientBuilder.ServiceBusReceiverClientBuilder Clase

  • java.lang.Object
    • com.azure.messaging.servicebus.ServiceBusClientBuilder.ServiceBusReceiverClientBuilder

public final class ServiceBusClientBuilder.ServiceBusReceiverClientBuilder

Generador para crear ServiceBusReceiverClient y ServiceBusReceiverAsyncClient consumir mensajes de Service Bus.

Resumen del método

Modificador y tipo Método y descripción
ServiceBusReceiverAsyncClient buildAsyncClient()

Crea un receptor asincrónico de Service Bus responsable de leer ServiceBusMessage desde una cola o suscripción específica.

ServiceBusReceiverClient buildClient()

Crea un receptor de Service Bus sincrónico responsable de leer ServiceBusMessage desde una cola o suscripción específica.

ServiceBusReceiverClientBuilder disableAutoComplete()

Deshabilita el autocompletar y el abandono automático de los mensajes recibidos.

ServiceBusReceiverClientBuilder maxAutoLockRenewDuration(Duration maxAutoLockRenewDuration)

Establece la cantidad de tiempo que se va a continuar renovando automáticamente el bloqueo.

ServiceBusReceiverClientBuilder prefetchCount(int prefetchCount)

Establece el recuento de capturas previas del receptor.

ServiceBusReceiverClientBuilder queueName(String queueName)

Establece el nombre de la cola para la que se va a crear un receptor.

ServiceBusReceiverClientBuilder receiveMode(ServiceBusReceiveMode receiveMode)

Establece el modo de recepción para el receptor.

ServiceBusReceiverClientBuilder subQueue(SubQueue subQueue)

Establece el tipo de al que SubQueue se va a conectar.

ServiceBusReceiverClientBuilder subscriptionName(String subscriptionName)

Establece el nombre de la suscripción en el tema al que se va a escuchar.

ServiceBusReceiverClientBuilder topicName(String topicName)

Establece el nombre del tema.

Métodos heredados de java.lang.Object

Detalles del método

buildAsyncClient

public ServiceBusReceiverAsyncClient buildAsyncClient()

Crea un receptor asincrónico de Service Bus responsable de leer ServiceBusMessage desde una cola o suscripción específica.

Returns:

Nuevo ServiceBusReceiverAsyncClient que recibe mensajes de una cola o suscripción.

buildClient

public ServiceBusReceiverClient buildClient()

Crea un receptor de Service Bus sincrónico responsable de leer ServiceBusMessage desde una cola o suscripción específica.

Returns:

Nuevo ServiceBusReceiverClient que recibe mensajes de una cola o suscripción.

disableAutoComplete

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder disableAutoComplete()

Deshabilita el autocompletar y el abandono automático de los mensajes recibidos. De forma predeterminada, un mensaje procesado correctamente es complete(ServiceBusReceivedMessage message). Si se produce un error cuando se procesa el mensaje, es abandon(ServiceBusReceivedMessage message).

Returns:

El objeto ServiceBusReceiverClientBuilder modificado.

maxAutoLockRenewDuration

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder maxAutoLockRenewDuration(Duration maxAutoLockRenewDuration)

Establece la cantidad de tiempo que se va a continuar renovando automáticamente el bloqueo. Al establecer Duration#ZERO o null deshabilitar la renovación automática. En RECEIVE_AND_DELETE el modo , la renovación automática está deshabilitada.

Parameters:

maxAutoLockRenewDuration - la cantidad de tiempo que se va a seguir renovando automáticamente el bloqueo. Duration#ZERO o null indica que la renovación automática está deshabilitada.

Returns:

Objeto ServiceBusReceiverClientBuilder actualizado.

prefetchCount

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder prefetchCount(int prefetchCount)

Establece el recuento de capturas previas del receptor. Para los PEEK_LOCK modos y RECEIVE_AND_DELETE , el valor predeterminado es 1. La captura previa acelera el flujo de mensajes con el objetivo de tener un mensaje fácilmente disponible para la recuperación local cuando y antes de que la aplicación solicite una mediante receiveMessages(). Si se establece un valor distinto de cero, se captura previamente ese número de mensajes. Al establecer el valor en cero, se desactiva la captura previa.

Parameters:

prefetchCount - Recuento de capturas previas.

Returns:

El objeto ServiceBusReceiverClientBuilder modificado.

queueName

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder queueName(String queueName)

Establece el nombre de la cola para la que se va a crear un receptor.

Parameters:

queueName - Nombre de la cola.

Returns:

El objeto ServiceBusReceiverClientBuilder modificado.

receiveMode

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder receiveMode(ServiceBusReceiveMode receiveMode)

Establece el modo de recepción para el receptor.

Parameters:

receiveMode - Modo para recibir mensajes.

Returns:

El objeto ServiceBusReceiverClientBuilder modificado.

subQueue

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder subQueue(SubQueue subQueue)

Establece el tipo de al que SubQueue se va a conectar.

Parameters:

subQueue - Tipo de la sub cola.

Returns:

El objeto ServiceBusReceiverClientBuilder modificado.

subscriptionName

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder subscriptionName(String subscriptionName)

Establece el nombre de la suscripción en el tema al que se va a escuchar. topicName(String topicName) también debe establecerse.

Parameters:

subscriptionName - Nombre de la suscripción.

Returns:

El objeto ServiceBusReceiverClientBuilder modificado.

topicName

public ServiceBusClientBuilder.ServiceBusReceiverClientBuilder topicName(String topicName)

Establece el nombre del tema. subscriptionName(String subscriptionName) también debe establecerse.

Parameters:

topicName - Nombre del tema.

Returns:

El objeto ServiceBusReceiverClientBuilder modificado.

Se aplica a