Compartir a través de


ServiceBusReceiver Clase

Definición

ServiceBusReceiver es responsable de recibir y liquidar ServiceBusReceivedMessage mensajes de colas y suscripciones. Se construye mediante una llamada a CreateReceiver(String, ServiceBusReceiverOptions).

public class ServiceBusReceiver : IAsyncDisposable
type ServiceBusReceiver = class
    interface IAsyncDisposable
Public Class ServiceBusReceiver
Implements IAsyncDisposable
Herencia
ServiceBusReceiver
Derivado
Implementaciones

Comentarios

ServiceBusReceiver es seguro almacenar en caché y usar durante la vigencia de una aplicación o hasta que se elimine el ServiceBusClient objeto que creó. Se recomienda almacenar en caché el receptor cuando la aplicación consume mensajes periódicamente o semestralmente. El receptor es responsable de garantizar un uso eficaz de la red, la CPU y la memoria. Al llamar DisposeAsync() a en el asociado ServiceBusClient a medida que se cierra la aplicación, se asegurará de que los recursos de red y otros objetos no administrados usados por el receptor se limpien correctamente.

Constructores

ServiceBusReceiver()

Inicializa una nueva instancia de la ServiceBusReceiver clase para simular.

ServiceBusReceiver(ServiceBusClient, String, ServiceBusReceiverOptions)

Inicializa una nueva instancia de la ServiceBusReceiver clase para su uso con tipos derivados.

ServiceBusReceiver(ServiceBusClient, String, String, ServiceBusReceiverOptions)

Inicializa una nueva instancia de la ServiceBusReceiver clase para su uso con tipos derivados.

Propiedades

EntityPath

Ruta de acceso de la entidad de Service Bus a la que está conectado el receptor, específica del espacio de nombres de Service Bus que lo contiene.

FullyQualifiedNamespace

Espacio de nombres completo de Service Bus al que está asociado el receptor. Es probable que sea similar a {yournamespace}.servicebus.windows.net.

Identifier

Nombre que se usa para identificar al cliente receptor. Si null o está vacío, se usará un valor único aleatorio.

IsClosed

Indica si se ServiceBusReceiver ha cerrado o no.

PrefetchCount

El número de mensajes que se solicitarán diligentemente desde colas o suscripciones y en cola localmente sin tener en cuenta si un procesamiento está activo actualmente, destinado a ayudar a maximizar el rendimiento al permitir que el receptor reciba de una caché local en lugar de esperar a una solicitud de servicio.

ReceiveMode

que ReceiveMode se usa para especificar cómo se reciben los mensajes.

Métodos

AbandonMessageAsync(ServiceBusReceivedMessage, IDictionary<String,Object>, CancellationToken)

Abandona un ServiceBusReceivedMessageobjeto . Esto hará que el mensaje esté disponible de nuevo para su procesamiento inmediato, ya que se liberará el bloqueo del mensaje que mantiene el receptor.

CloseAsync(CancellationToken)

Realiza la tarea necesaria para limpiar los recursos utilizados por .ServiceBusReceiver

CompleteMessageAsync(ServiceBusReceivedMessage, CancellationToken)

Completa un ServiceBusReceivedMessageobjeto . Esto eliminará el mensaje del servicio.

DeadLetterMessageAsync(ServiceBusReceivedMessage, IDictionary<String,Object>, CancellationToken)

Mueve un mensaje a la subconsulta de mensajes fallidos.

DeadLetterMessageAsync(ServiceBusReceivedMessage, IDictionary<String,Object>, String, String, CancellationToken)

Mueve un mensaje a la subconsulta de mensajes fallidos.

DeadLetterMessageAsync(ServiceBusReceivedMessage, String, String, CancellationToken)

Mueve un mensaje a la subconsulta de mensajes fallidos.

DeferMessageAsync(ServiceBusReceivedMessage, IDictionary<String,Object>, CancellationToken)

Indica que el receptor quiere aplazar el procesamiento del mensaje.

DisposeAsync()

Realiza la tarea necesaria para limpiar los recursos utilizados por .ServiceBusReceiver Esto equivale a llamar a CloseAsync(CancellationToken).

PeekMessageAsync(Nullable<Int64>, CancellationToken)

Captura el siguiente activo ServiceBusReceivedMessage sin cambiar el estado del receptor o el origen del mensaje.

PeekMessagesAsync(Int32, Nullable<Int64>, CancellationToken)

ServiceBusReceiver es responsable de recibir y liquidar ServiceBusReceivedMessage mensajes de colas y suscripciones. Se construye mediante una llamada a CreateReceiver(String, ServiceBusReceiverOptions).

ReceiveDeferredMessageAsync(Int64, CancellationToken)

Recibe un mensaje diferido identificado por sequenceNumber.

ReceiveDeferredMessagesAsync(IEnumerable<Int64>, CancellationToken)

Recibe una lista de mensajes diferidos identificados por sequenceNumbers.

ReceiveMessageAsync(Nullable<TimeSpan>, CancellationToken)

Recibe un ServiceBusReceivedMessage de la entidad mediante ReceiveMode el modo . ReceiveMode tiene como valor predeterminado el modo PeekLock.

ReceiveMessagesAsync(CancellationToken)

Recibe mensajes como enumerable asincrónico de la entidad mediante ReceiveMode el modo . ReceiveMode tiene como valor predeterminado el modo PeekLock. Los mensajes se recibirán de la entidad a medida que se itera IAsyncEnumerable. Si no hay ningún mensaje disponible, este método continuará sondeando hasta que los mensajes estén disponibles, es decir, nunca devolverá null.

ReceiveMessagesAsync(Int32, Nullable<TimeSpan>, CancellationToken)

Recibe una lista de la ServiceBusReceivedMessage entidad mediante ReceiveMode el modo . ReceiveMode tiene como valor predeterminado el modo PeekLock. Este método no garantiza que devuelva mensajes exactos maxMessages , incluso si hay maxMessages mensajes disponibles en la cola o el tema.

RenewMessageLockAsync(ServiceBusReceivedMessage, CancellationToken)

Renueva el bloqueo en el mensaje. El bloqueo se renovará en función de la configuración especificada en la cola.

Se aplica a