IMessageSession Interface

Referência

Definição

Namespace:: Microsoft.Azure.ServiceBus

Assembly:: Microsoft.Azure.ServiceBus.dll

Pacote:: Microsoft.Azure.ServiceBus v5.2.0

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.

Descreve um objeto Session. O IMessageSession pode ser usado para executar operações em sessões.

public interface IMessageSession : Microsoft.Azure.ServiceBus.Core.IMessageReceiver

type IMessageSession = interface
    interface IMessageReceiver
    interface IReceiverClient
    interface IClientEntity

Public Interface IMessageSession
Implements IMessageReceiver

Implementações: IMessageReceiver IReceiverClient IClientEntity

Comentários

As sessões do Barramento de Serviço, também chamadas de "Grupos" no protocolo AMQP 1.0, são sequências não associadas de mensagens relacionadas. O ServiceBus garante a ordenação de mensagens em uma sessão.

Qualquer remetente pode criar uma sessão ao enviar mensagens para um Tópico ou Fila definindo a SessionId propriedade em Mensagem para algum identificador exclusivo definido pelo aplicativo. No nível do protocolo AMQP 1.0, esse valor é mapeado para a propriedade group-id.

As sessões surgem quando há pelo menos uma mensagem com SessionId da sessão na assinatura Fila ou Tópico. Depois que uma Sessão existe, não há nenhum momento ou gesto definido para quando a sessão expira ou desaparece.

Propriedades

ClientId	Obtém a ID para identificar esse cliente. Isso pode ser usado para correlacionar logs e exceções. (Herdado de IClientEntity)
IsClosedOrClosing	Retornará true se o cliente estiver fechado ou fechado. (Herdado de IClientEntity)
LastPeekedSequenceNumber	Obtém o número de sequência da última mensagem espiada. (Herdado de IMessageReceiver)
LockedUntilUtc	Obtém o tempo pelo qual a sessão identificada por SessionId está bloqueada até que esse cliente seja bloqueado.
OperationTimeout	Duração após a qual as operações individuais atingirão o tempo limite. (Herdado de IClientEntity)
OwnsConnection	Retornará true se a conexão for de propriedade e false se a conexão for compartilhada. (Herdado de IClientEntity)
Path	Obtém o caminho da entidade. (Herdado de IClientEntity)
PrefetchCount	A pré-busca acelera o fluxo de mensagens com o objetivo de ter uma mensagem prontamente disponível para recuperação local quando e antes que o aplicativo solicite uma usando Receive. Definir um valor diferente de zero pré-busca o número prefetchCount de mensagens. Definir o valor como zero desativa a pré-busca. Assume o padrão de 0. (Herdado de IReceiverClient)
ReceiveMode	Obtém o ReceiveMode do receptor atual. (Herdado de IReceiverClient)
RegisteredPlugins	Obtém uma lista de plug-ins registrados no momento para esse cliente. (Herdado de IClientEntity)
ServiceBusConnection	Objeto de conexão com o namespace do barramento de serviço. (Herdado de IClientEntity)
SessionId	Obtém a SessionId.

Métodos

AbandonAsync(String, IDictionary<String,Object>)	Abandona um Message usando um token de bloqueio. Isso disponibilizará a mensagem novamente para processamento. (Herdado de IReceiverClient)
CloseAsync()	Fecha o Cliente. Fecha as conexões abertas por ela. (Herdado de IClientEntity)
CompleteAsync(IEnumerable<String>)	Conclui uma série de Message usando uma lista de tokens de bloqueio. Isso excluirá a mensagem do serviço. (Herdado de IMessageReceiver)
CompleteAsync(String)	Conclui um Message usando seu token de bloqueio. Isso excluirá a mensagem da fila. (Herdado de IReceiverClient)
DeadLetterAsync(String, IDictionary<String,Object>)	Move uma mensagem para a sub-fila de deadletter. (Herdado de IReceiverClient)
DeadLetterAsync(String, String, String)	Move uma mensagem para a sub-fila de deadletter. (Herdado de IReceiverClient)
DeferAsync(String, IDictionary<String,Object>)	Indica que o receptor deseja adiar o processamento da mensagem. (Herdado de IMessageReceiver)
GetStateAsync()	Obtém o estado da sessão.
PeekAsync()	Busca a próxima mensagem ativa sem alterar o estado do receptor ou a origem da mensagem. (Herdado de IMessageReceiver)
PeekAsync(Int32)	Busca o próximo lote de mensagens ativas sem alterar o estado do receptor ou a origem da mensagem. (Herdado de IMessageReceiver)
PeekBySequenceNumberAsync(Int64)	Lê de forma assíncrona a próxima mensagem sem alterar o estado do receptor ou a origem da mensagem. (Herdado de IMessageReceiver)
PeekBySequenceNumberAsync(Int64, Int32)	Espia um lote de mensagens. (Herdado de IMessageReceiver)
ReceiveAsync()	Receba uma mensagem da entidade definida usando Path ReceiveMode o modo . (Herdado de IMessageReceiver)
ReceiveAsync(Int32)	Recebe um máximo de `maxMessageCount` mensagens da entidade definida usando Path ReceiveMode o modo . (Herdado de IMessageReceiver)
ReceiveAsync(Int32, TimeSpan)	Recebe um máximo de `maxMessageCount` mensagens da entidade definida usando Path ReceiveMode o modo . (Herdado de IMessageReceiver)
ReceiveAsync(TimeSpan)	Receba uma mensagem da entidade definida usando Path ReceiveMode o modo . (Herdado de IMessageReceiver)
ReceiveDeferredMessageAsync(IEnumerable<Int64>)	Recebe uma IList<T> das mensagens adiadas identificadas por `sequenceNumbers`. (Herdado de IMessageReceiver)
ReceiveDeferredMessageAsync(Int64)	Recebe uma mensagem adiada específica identificada por `sequenceNumber`. (Herdado de IMessageReceiver)
RegisterMessageHandler(Func<Message,CancellationToken,Task>, Func<ExceptionReceivedEventArgs,Task>)	Receber mensagens continuamente da entidade. Registra um manipulador de mensagens e inicia um novo thread para receber mensagens. Esse manipulador(Func<T1,T2,TResult>) é aguardado sempre que uma nova mensagem é recebida pelo receptor. (Herdado de IReceiverClient)
RegisterMessageHandler(Func<Message,CancellationToken,Task>, MessageHandlerOptions)	Receber mensagens continuamente da entidade. Registra um manipulador de mensagens e inicia um novo thread para receber mensagens. Esse manipulador(Func<T1,T2,TResult>) é aguardado sempre que uma nova mensagem é recebida pelo receptor. (Herdado de IReceiverClient)
RegisterPlugin(ServiceBusPlugin)	Registra um ServiceBusPlugin a ser usado com esse cliente. (Herdado de IClientEntity)
RenewLockAsync(Message)	Renova o bloqueio na mensagem. O bloqueio será renovado com base na configuração especificada na fila. (Herdado de IMessageReceiver)
RenewLockAsync(String)	Renova o bloqueio na mensagem. O bloqueio será renovado com base na configuração especificada na fila. Nova data e hora de expiração do token de bloqueio no formato UTC. (Herdado de IMessageReceiver)
RenewSessionLockAsync()	Renova o bloqueio na sessão especificada pelo SessionId. O bloqueio será renovado com base na configuração especificada na entidade .
SetStateAsync(Byte[])	Definir um estado personalizado na sessão que pode ser recuperado posteriormente usando GetStateAsync()
UnregisterMessageHandlerAsync(TimeSpan)	Cancele o registro do manipulador de mensagens do receptor se houver um manipulador de mensagens ativo registrado. Esta operação aguarda a conclusão das operações de recebimento e tratamento de mensagens a bordo para concluir e cancelar o registro de recebimentos futuros no manipulador de mensagens registrado anteriormente. (Herdado de IReceiverClient)
UnregisterPlugin(String)	Cancela o registro de um ServiceBusPlugin. (Herdado de IClientEntity)

Aplica-se a

Compartilhar via