Partilhar via


IMessageSession Interface

Definição

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

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 PathReceiveMode o modo .

(Herdado de IMessageReceiver)
ReceiveAsync(Int32)

Recebe um máximo de maxMessageCount mensagens da entidade definida usando PathReceiveMode o modo .

(Herdado de IMessageReceiver)
ReceiveAsync(Int32, TimeSpan)

Recebe um máximo de maxMessageCount mensagens da entidade definida usando PathReceiveMode o modo .

(Herdado de IMessageReceiver)
ReceiveAsync(TimeSpan)

Receba uma mensagem da entidade definida usando PathReceiveMode 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