SessionClient Class

Reference

Definition

Namespace:: Microsoft.Azure.ServiceBus

Assembly:

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

A session client can be used to accept session objects which can be used to interact with all messages with the same 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

Inheritance: System.Object

ClientEntity
SessionClient

Implements: ISessionClient

Examples

To create a new SessionClient

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

To receive a session object for a given sessionId

IMessageSession session = await sessionClient.AcceptMessageSessionAsync(sessionId);

To receive any session

IMessageSession session = await sessionClient.AcceptMessageSessionAsync();

Remarks

You can accept any session or a given session (identified by SessionId using a session client. Once you accept a session, you can use it as a MessageReceiver which receives only messages having the same session id. See IMessageSession for usage of session object. This uses AMQP protocol to communicate with the service.

Constructors

SessionClient(ServiceBusConnectionStringBuilder, ReceiveMode, RetryPolicy, Int32)	Creates a new SessionClient from a ServiceBusConnectionStringBuilder
SessionClient(String, String, ReceiveMode, RetryPolicy, Int32)	Creates a new SessionClient from a specified connection string and entity path.

Properties

ClientId	Gets the ID to identify this client. This can be used to correlate logs and exceptions. (Inherited from ClientEntity)
EntityPath	Gets the path of the entity. This is either the name of the queue, or the full path of the subscription.
IsClosedOrClosing	Returns true if the client is closed or closing. (Inherited from ClientEntity)
OperationTimeout	Duration after which individual operations will timeout.
RegisteredPlugins	Gets a list of currently registered plugins.
RetryPolicy	Gets the RetryPolicy defined on the client. (Inherited from ClientEntity)

Methods

AcceptMessageSessionAsync()	Gets a session object of any SessionId that can be used to receive messages for that sessionId.
AcceptMessageSessionAsync(String)	Gets a particular session object identified by `sessionId` that can be used to receive messages for that sessionId.
AcceptMessageSessionAsync(String, TimeSpan)	Gets a particular session object identified by `sessionId` that can be used to receive messages for that sessionId.
AcceptMessageSessionAsync(TimeSpan)	Gets a session object of any SessionId that can be used to receive messages for that sessionId.
CloseAsync()	Closes the Client. Closes the connections opened by it. (Inherited from ClientEntity)
OnClosingAsync()	(Inherited from ClientEntity)
RegisterPlugin(ServiceBusPlugin)	Registers a ServiceBusPlugin to be used with this receiver.
ThrowIfClosed()	Throw an OperationCanceledException if the object is Closing. (Inherited from ClientEntity)
UnregisterPlugin(String)	Unregisters a ServiceBusPlugin.

Applies to