Compartilhar via


ServiceBusReceiver Classe

Definição

O ServiceBusReceiver é responsável por receber ServiceBusReceivedMessage e resolver mensagens de Filas e Assinaturas. Ele é construído chamando CreateReceiver(String, ServiceBusReceiverOptions).

public class ServiceBusReceiver : IAsyncDisposable
type ServiceBusReceiver = class
    interface IAsyncDisposable
Public Class ServiceBusReceiver
Implements IAsyncDisposable
Herança
ServiceBusReceiver
Derivado
Implementações

Comentários

O ServiceBusReceiver é seguro para armazenar em cache e usar durante o tempo de vida de um aplicativo ou até que o ServiceBusClient pelo qual ele foi criado seja descartado. O cache do receptor é recomendado quando o aplicativo está consumindo mensagens regularmente ou semi regularmente. O receptor é responsável por garantir o uso eficiente de rede, CPU e memória. Chamar DisposeAsync() no associado ServiceBusClient , pois o aplicativo está sendo desligado, garantirá que os recursos de rede e outros objetos não gerenciados usados pelo receptor sejam limpos corretamente.

Construtores

ServiceBusReceiver()

Inicializa uma nova instância da ServiceBusReceiver classe para simulação.

ServiceBusReceiver(ServiceBusClient, String, ServiceBusReceiverOptions)

Inicializa uma nova instância da ServiceBusReceiver classe para uso com tipos derivados.

ServiceBusReceiver(ServiceBusClient, String, String, ServiceBusReceiverOptions)

Inicializa uma nova instância da ServiceBusReceiver classe para uso com tipos derivados.

Propriedades

EntityPath

O caminho da entidade do Barramento de Serviço à qual o receptor está conectado, específico ao namespace do Barramento de Serviço que o contém.

FullyQualifiedNamespace

O namespace do Barramento de Serviço totalmente qualificado ao qual o receptor está associado. É provável que isso seja semelhante a {yournamespace}.servicebus.windows.net.

Identifier

Um nome usado para identificar o cliente receptor. Se null ou estiver vazio, um valor exclusivo aleatório será usado.

IsClosed

Indica se isso ServiceBusReceiver foi ou não fechado.

PrefetchCount

O número de mensagens que serão solicitadas ansiosamente de Filas ou Assinaturas e enfileiradas localmente sem considerar se um processamento está ativo no momento, destinado a ajudar a maximizar a taxa de transferência, permitindo que o receptor receba de um cache local em vez de aguardar uma solicitação de serviço

ReceiveMode

O ReceiveMode usado para especificar como as mensagens são recebidas.

Métodos

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

Abandona um ServiceBusReceivedMessage. Isso disponibilizará a mensagem novamente para processamento imediato, pois o bloqueio na mensagem mantida pelo receptor será liberado.

CloseAsync(CancellationToken)

Executa a tarefa necessária para limpo recursos usados pelo ServiceBusReceiver.

CompleteMessageAsync(ServiceBusReceivedMessage, CancellationToken)

Conclui um ServiceBusReceivedMessage. Isso excluirá a mensagem do serviço.

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

Move uma mensagem para a subguia de mensagens mortas.

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

Move uma mensagem para a subguia de mensagens mortas.

DeadLetterMessageAsync(ServiceBusReceivedMessage, String, String, CancellationToken)

Move uma mensagem para a subguia de mensagens mortas.

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

Indica que o receptor deseja adiar o processamento da mensagem.

DisposeAsync()

Executa a tarefa necessária para limpo recursos usados pelo ServiceBusReceiver. Isso é equivalente a chamar CloseAsync(CancellationToken).

PeekMessageAsync(Nullable<Int64>, CancellationToken)

Busca o próximo ativo ServiceBusReceivedMessage sem alterar o estado do receptor ou da origem da mensagem.

PeekMessagesAsync(Int32, Nullable<Int64>, CancellationToken)

O ServiceBusReceiver é responsável por receber ServiceBusReceivedMessage e resolver mensagens de Filas e Assinaturas. Ele é construído chamando CreateReceiver(String, ServiceBusReceiverOptions).

ReceiveDeferredMessageAsync(Int64, CancellationToken)

Recebe uma mensagem adiada identificada por sequenceNumber.

ReceiveDeferredMessagesAsync(IEnumerable<Int64>, CancellationToken)

Recebe uma lista de mensagens adiadas identificadas por sequenceNumbers.

ReceiveMessageAsync(Nullable<TimeSpan>, CancellationToken)

Recebe um ServiceBusReceivedMessage da entidade usando ReceiveMode o modo . ReceiveMode usa como padrão o modo PeekLock.

ReceiveMessagesAsync(CancellationToken)

Recebe mensagens como um enumerável assíncrono da entidade usando ReceiveMode o modo . ReceiveMode usa como padrão o modo PeekLock. As mensagens serão recebidas da entidade à medida que iAsyncEnumerable for iterado. Se nenhuma mensagem estiver disponível, esse método continuará sondando até que as mensagens estejam disponíveis, ou seja, ele nunca retornará nulo.

ReceiveMessagesAsync(Int32, Nullable<TimeSpan>, CancellationToken)

Recebe uma lista de ServiceBusReceivedMessage da entidade usando ReceiveMode o modo . ReceiveMode usa como padrão o modo PeekLock. Esse método não garante o retorno de mensagens exatas maxMessages , mesmo que haja maxMessages mensagens disponíveis na fila ou no tópico.

RenewMessageLockAsync(ServiceBusReceivedMessage, CancellationToken)

Renova o bloqueio na mensagem. O bloqueio será renovado com base na configuração especificada na fila.

Aplica-se a