SessionClient Classe

Referência

Definição

Namespace:: Microsoft.Azure.ServiceBus

Assembly:: Microsoft.Azure.ServiceBus.dll

Pacote:: Microsoft.Azure.ServiceBus v5.2.0

Origem:: SessionClient.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.

Um cliente de sessão pode ser usado para aceitar objetos de sessão que podem ser usados para interagir com todas as mensagens com a mesma sessionId.

public sealed class SessionClient : Microsoft.Azure.ServiceBus.ClientEntity, Microsoft.Azure.ServiceBus.ISessionClient

type SessionClient = class
    inherit ClientEntity
    interface ISessionClient
    interface IClientEntity

Public NotInheritable Class SessionClient
Inherits ClientEntity
Implements ISessionClient

Herança: Object

ClientEntity
SessionClient

Implementações: IClientEntity ISessionClient

Exemplos

Para criar um novo SessionClient

ISessionClient sessionClient = new SessionClient(
    namespaceConnectionString,
    queueName,
    ReceiveMode.PeekLock);

Para receber um objeto de sessão para uma determinada sessionId

IMessageSession session = await sessionClient.AcceptMessageSessionAsync(sessionId);

Para receber qualquer sessão

IMessageSession session = await sessionClient.AcceptMessageSessionAsync();

Comentários

Você pode aceitar qualquer sessão ou uma determinada sessão (identificada SessionId usando um cliente de sessão. Depois de aceitar uma sessão, você poderá usá-la como uma MessageReceiver que recebe apenas mensagens com a mesma ID de sessão. Consulte IMessageSession para obter o uso do objeto de sessão. Isso usa o protocolo AMQP para se comunicar com o serviço.

Construtores

SessionClient(ServiceBusConnection, String, ReceiveMode, RetryPolicy, Int32)	Cria um novo SessionClient em um determinado ServiceBusConnection
SessionClient(ServiceBusConnectionStringBuilder, ReceiveMode, RetryPolicy, Int32)	Cria um novo SessionClient de um ServiceBusConnectionStringBuilder
SessionClient(String, String, ITokenProvider, TransportType, ReceiveMode, RetryPolicy, Int32)	Cria um novo SessionClient de um ponto de extremidade, caminho de entidade e provedor de token especificados.
SessionClient(String, String, ReceiveMode, RetryPolicy, Int32)	Cria um novo SessionClient de uma cadeia de conexão e um caminho de entidade especificados.

Propriedades

ClientId	Obtém a ID para identificar esse cliente. Isso pode ser usado para correlacionar logs e exceções. (Herdado de ClientEntity)
EntityPath	Obtém o caminho da entidade. Esse é o nome da fila ou o caminho completo da assinatura.
IsClosedOrClosing	Retornará true se o cliente estiver fechado ou fechado. (Herdado de ClientEntity)
OperationTimeout	Duração após a qual as operações individuais terão tempo limite.
OwnsConnection	Retornará true se a conexão for de propriedade e false se a conexão for compartilhada. (Herdado de ClientEntity)
Path	Obtém o caminho da entidade. Esse é o nome da fila ou o caminho completo da assinatura.
RegisteredPlugins	Obtém uma lista de plug-ins registrados no momento.
RetryPolicy	Obtém o RetryPolicy definido no cliente. (Herdado de ClientEntity)
ServiceBusConnection	Objeto de conexão com o namespace do barramento de serviço.

Métodos

AcceptMessageSessionAsync()	Obtém um objeto de sessão de qualquer SessionId que possa ser usado para receber mensagens para essa sessionId.
AcceptMessageSessionAsync(String)	Obtém um objeto de sessão específico identificado por `sessionId` que pode ser usado para receber mensagens para essa sessionId.
AcceptMessageSessionAsync(String, TimeSpan)	Obtém um objeto de sessão específico identificado por `sessionId` que pode ser usado para receber mensagens para essa sessionId.
AcceptMessageSessionAsync(TimeSpan)	Obtém um objeto de sessão de qualquer SessionId que possa ser usado para receber mensagens para essa sessionId.
CloseAsync()	Fecha o Cliente. Fecha as conexões abertas por ela. (Herdado de ClientEntity)
OnClosingAsync()	Um cliente de sessão pode ser usado para aceitar objetos de sessão que podem ser usados para interagir com todas as mensagens com a mesma sessionId. (Herdado de ClientEntity)
RegisterPlugin(ServiceBusPlugin)	Registra um ServiceBusPlugin a ser usado com esse receptor.
ThrowIfClosed()	Gere uma OperationCanceledException se o objeto estiver fechando. (Herdado de ClientEntity)
UnregisterPlugin(String)	Cancela o registro de um ServiceBusPlugin.

Aplica-se a

Confira também

IMessageSession

Compartilhar via