ServiceBusReceiver Classe

Referência

Definição

Namespace:: Azure.Messaging.ServiceBus

Assembly:: Azure.Messaging.ServiceBus.dll

Pacote:: Azure.Messaging.ServiceBus v7.17.5

Origem:: ServiceBusReceiver.cs

Importante

Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.

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: Object
ServiceBusReceiver

Derivado: Azure.Messaging.ServiceBus.ServiceBusSessionReceiver

Implementações: IAsyncDisposable

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

Compartilhar via