ServiceBusSessionReceiver Classe

Definição

O ServiceBusSessionReceiver é responsável por receber ServiceBusReceivedMessage e resolver mensagens de filas e assinaturas habilitadas para sessão. Ele é construído chamando AcceptNextSessionAsync(String, String, ServiceBusSessionReceiverOptions, CancellationToken).

public class ServiceBusSessionReceiver : Azure.Messaging.ServiceBus.ServiceBusReceiver
type ServiceBusSessionReceiver = class
    inherit ServiceBusReceiver
Public Class ServiceBusSessionReceiver
Inherits ServiceBusReceiver
Herança
ServiceBusSessionReceiver

Construtores

ServiceBusSessionReceiver()

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

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.

(Herdado de ServiceBusReceiver)
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.

(Herdado de ServiceBusReceiver)
Identifier

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

(Herdado de ServiceBusReceiver)
IsClosed

Indica se isso ServiceBusSessionReceiver foi ou não fechado pelo usuário ou se o link da sessão subjacente foi fechado devido à perda do bloqueio de sessão ou à desconexão do link. Se for true, o receptor não poderá ser usado para mais operações. Se for false, ainda será possível que o bloqueio de sessão tenha sido perdido, portanto, é importante ainda lidar ServiceBusException com igual Reason a SessionLockLost.

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

(Herdado de ServiceBusReceiver)
ReceiveMode

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

(Herdado de ServiceBusReceiver)
SessionId

A ID da sessão associada ao receptor.

SessionLockedUntil

Obtém o DateTimeOffset que a sessão do receptor está bloqueada até.

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.

(Herdado de ServiceBusReceiver)
CloseAsync(CancellationToken)

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

(Herdado de ServiceBusReceiver)
CompleteMessageAsync(ServiceBusReceivedMessage, CancellationToken)

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

(Herdado de ServiceBusReceiver)
DeadLetterMessageAsync(ServiceBusReceivedMessage, IDictionary<String,Object>, CancellationToken)

Move uma mensagem para a subguia de mensagens mortas.

(Herdado de ServiceBusReceiver)
DeadLetterMessageAsync(ServiceBusReceivedMessage, IDictionary<String,Object>, String, String, CancellationToken)

Move uma mensagem para a subguia de mensagens mortas.

(Herdado de ServiceBusReceiver)
DeadLetterMessageAsync(ServiceBusReceivedMessage, String, String, CancellationToken)

Move uma mensagem para a subguia de mensagens mortas.

(Herdado de ServiceBusReceiver)
DeferMessageAsync(ServiceBusReceivedMessage, IDictionary<String,Object>, CancellationToken)

Indica que o receptor deseja adiar o processamento da mensagem.

(Herdado de ServiceBusReceiver)
DisposeAsync()

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

(Herdado de ServiceBusReceiver)
GetSessionStateAsync(CancellationToken)

Obtém o estado da sessão.

PeekMessageAsync(Nullable<Int64>, CancellationToken)

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

(Herdado de ServiceBusReceiver)
PeekMessagesAsync(Int32, Nullable<Int64>, CancellationToken)

O ServiceBusSessionReceiver é responsável por receber ServiceBusReceivedMessage e resolver mensagens de filas e assinaturas habilitadas para sessão. Ele é construído chamando AcceptNextSessionAsync(String, String, ServiceBusSessionReceiverOptions, CancellationToken).

(Herdado de ServiceBusReceiver)
ReceiveDeferredMessageAsync(Int64, CancellationToken)

Recebe uma mensagem adiada identificada por sequenceNumber.

(Herdado de ServiceBusReceiver)
ReceiveDeferredMessagesAsync(IEnumerable<Int64>, CancellationToken)

Recebe uma lista de mensagens adiadas identificadas por sequenceNumbers.

(Herdado de ServiceBusReceiver)
ReceiveMessageAsync(Nullable<TimeSpan>, CancellationToken)

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

(Herdado de ServiceBusReceiver)
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.

(Herdado de ServiceBusReceiver)
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.

(Herdado de ServiceBusReceiver)
RenewMessageLockAsync(ServiceBusReceivedMessage, CancellationToken)

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

(Herdado de ServiceBusReceiver)
RenewSessionLockAsync(CancellationToken)

Renova o bloqueio na sessão especificada pelo SessionId. O bloqueio será renovado com base na configuração especificada na entidade.

SetSessionStateAsync(BinaryData, CancellationToken)

Definir um estado personalizado na sessão que pode ser recuperado posteriormente usando GetSessionStateAsync(CancellationToken)

Aplica-se a