Compartilhar via


SessionClient Classe

Definição

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
SessionClient
Implementações

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