SubscriptionClient SubscriptionClient SubscriptionClient SubscriptionClient SubscriptionClient SubscriptionClient Class

Definition

Namespace:
Microsoft.ServiceBus.Messaging Microsoft.ServiceBus.Messaging Microsoft.ServiceBus.Messaging Microsoft.ServiceBus.Messaging Microsoft.ServiceBus.Messaging Microsoft.ServiceBus.Messaging
Assembly:
Microsoft.ServiceBus.dll

Represents the anchor class used in run-time operations related to a topic subscription.

public ref class SubscriptionClient abstract : Microsoft::ServiceBus::Messaging::ClientEntity
[Windows::Foundation::Metadata::WebHostHidden]
public ref class SubscriptionClient abstract : Microsoft::ServiceBus::Messaging::ClientEntity
[Windows::Foundation::Metadata::WebHostHidden]
class SubscriptionClient abstract : Microsoft::ServiceBus::Messaging::ClientEntity
public abstract class SubscriptionClient : Microsoft.ServiceBus.Messaging.ClientEntity
type SubscriptionClient = class
    inherit ClientEntity
    interface IMessageSessionEntity
    interface IMessageClientEntity
    interface IMessageReceiver
    interface IMessageBrowser
Public MustInherit Class SubscriptionClient
Inherits ClientEntity
Inheritance
ObjectObjectObjectObjectObjectObject
ClientEntityClientEntityClientEntityClientEntityClientEntityClientEntity
SubscriptionClientSubscriptionClientSubscriptionClientSubscriptionClientSubscriptionClientSubscriptionClient

Examples


            // Create subscription client
            SubscriptionClient mySubscriptionClient = 
            factory.CreateSubscriptionClient(mySubscription);

            // Receive messages
            for (int count = 0; count < MsgCount; count++)
            {
                var message = mySubscriptionClient.Receive();
                message.Complete();
            }

Properties

IsClosed IsClosed IsClosed IsClosed IsClosed IsClosed Inherited from ClientEntity
MessagingFactory MessagingFactory MessagingFactory MessagingFactory MessagingFactory MessagingFactory

Gets the messaging factory used to create this subscription client.
Mode Mode Mode Mode Mode Mode

Gets the message receive mode when processing the received message.
Name Name Name Name Name Name

Gets the name of the subscription.
PrefetchCount PrefetchCount PrefetchCount PrefetchCount PrefetchCount PrefetchCount

Gets or sets the number of messages that the message receiver can simultaneously request.
RetryPolicy RetryPolicy RetryPolicy RetryPolicy RetryPolicy RetryPolicy Inherited from ClientEntity
ThisLock ThisLock ThisLock ThisLock ThisLock ThisLock Inherited from ClientEntity
TopicPath TopicPath TopicPath TopicPath TopicPath TopicPath

Gets the full pathname of the topic.

Methods

Abandon(Guid) Abandon(Guid) Abandon(Guid) Abandon(Guid) Abandon(Guid) Abandon(Guid)

Discards the message and relinquishes the message lock ownership.
Abandon(Guid, IDictionary<String,Object>) Abandon(Guid, IDictionary<String,Object>) Abandon(Guid, IDictionary<String,Object>) Abandon(Guid, IDictionary<String,Object>) Abandon(Guid, IDictionary<String,Object>) Abandon(Guid, IDictionary<String,Object>)

Discards the message and relinquishes the message lock ownership.
AbandonAsync(Guid) AbandonAsync(Guid) AbandonAsync(Guid) AbandonAsync(Guid) AbandonAsync(Guid) AbandonAsync(Guid)

Asynchronously discards the message and relinquishes the message lock ownership.
AbandonAsync(Guid, IDictionary<String,Object>) AbandonAsync(Guid, IDictionary<String,Object>) AbandonAsync(Guid, IDictionary<String,Object>) AbandonAsync(Guid, IDictionary<String,Object>) AbandonAsync(Guid, IDictionary<String,Object>) AbandonAsync(Guid, IDictionary<String,Object>)

Asynchronously discards the message and relinquishes the message lock ownership.
Abort() Abort() Abort() Abort() Abort() Abort()

Performs abort functionality on the messaging entity.

(Inherited from ClientEntity)
AcceptMessageSession() AcceptMessageSession() AcceptMessageSession() AcceptMessageSession() AcceptMessageSession() AcceptMessageSession()

Accepts a message session that allows grouping of related messages for processing in a single transaction.
AcceptMessageSession(Boolean) AcceptMessageSession(Boolean) AcceptMessageSession(Boolean) AcceptMessageSession(Boolean) AcceptMessageSession(Boolean) AcceptMessageSession(Boolean)
AcceptMessageSession(Boolean, TimeSpan) AcceptMessageSession(Boolean, TimeSpan) AcceptMessageSession(Boolean, TimeSpan) AcceptMessageSession(Boolean, TimeSpan) AcceptMessageSession(Boolean, TimeSpan) AcceptMessageSession(Boolean, TimeSpan)
AcceptMessageSession(String) AcceptMessageSession(String) AcceptMessageSession(String) AcceptMessageSession(String) AcceptMessageSession(String) AcceptMessageSession(String)

Accepts a message session that allows grouping of related messages for processing in a single transaction using the given session identifier.
AcceptMessageSession(String, Boolean) AcceptMessageSession(String, Boolean) AcceptMessageSession(String, Boolean) AcceptMessageSession(String, Boolean) AcceptMessageSession(String, Boolean) AcceptMessageSession(String, Boolean)
AcceptMessageSession(String, Boolean, TimeSpan) AcceptMessageSession(String, Boolean, TimeSpan) AcceptMessageSession(String, Boolean, TimeSpan) AcceptMessageSession(String, Boolean, TimeSpan) AcceptMessageSession(String, Boolean, TimeSpan) AcceptMessageSession(String, Boolean, TimeSpan)
AcceptMessageSession(String, Guid) AcceptMessageSession(String, Guid) AcceptMessageSession(String, Guid) AcceptMessageSession(String, Guid) AcceptMessageSession(String, Guid) AcceptMessageSession(String, Guid)
AcceptMessageSession(String, Guid, TimeSpan) AcceptMessageSession(String, Guid, TimeSpan) AcceptMessageSession(String, Guid, TimeSpan) AcceptMessageSession(String, Guid, TimeSpan) AcceptMessageSession(String, Guid, TimeSpan) AcceptMessageSession(String, Guid, TimeSpan)
AcceptMessageSession(String, TimeSpan) AcceptMessageSession(String, TimeSpan) AcceptMessageSession(String, TimeSpan) AcceptMessageSession(String, TimeSpan) AcceptMessageSession(String, TimeSpan) AcceptMessageSession(String, TimeSpan)

Accepts a message session that allows grouping of related messages for processing in a single transaction using the given session identifier and wait time.
AcceptMessageSession(TimeSpan) AcceptMessageSession(TimeSpan) AcceptMessageSession(TimeSpan) AcceptMessageSession(TimeSpan) AcceptMessageSession(TimeSpan) AcceptMessageSession(TimeSpan)

Accepts a message session that allows grouping of related messages for processing in a single transaction using the specified server wait time.
AcceptMessageSessionAsync() AcceptMessageSessionAsync() AcceptMessageSessionAsync() AcceptMessageSessionAsync() AcceptMessageSessionAsync() AcceptMessageSessionAsync()

Asynchronously accepts a message session that allows grouping of related messages for processing in a single transaction using the specified server wait time.
AcceptMessageSessionAsync(Boolean) AcceptMessageSessionAsync(Boolean) AcceptMessageSessionAsync(Boolean) AcceptMessageSessionAsync(Boolean) AcceptMessageSessionAsync(Boolean) AcceptMessageSessionAsync(Boolean)
AcceptMessageSessionAsync(Boolean, TimeSpan) AcceptMessageSessionAsync(Boolean, TimeSpan) AcceptMessageSessionAsync(Boolean, TimeSpan) AcceptMessageSessionAsync(Boolean, TimeSpan) AcceptMessageSessionAsync(Boolean, TimeSpan) AcceptMessageSessionAsync(Boolean, TimeSpan)
AcceptMessageSessionAsync(String) AcceptMessageSessionAsync(String) AcceptMessageSessionAsync(String) AcceptMessageSessionAsync(String) AcceptMessageSessionAsync(String) AcceptMessageSessionAsync(String)

Asynchronously accepts a message session that allows grouping of related messages for processing in a single transaction using the specified server wait time.
AcceptMessageSessionAsync(String, Boolean) AcceptMessageSessionAsync(String, Boolean) AcceptMessageSessionAsync(String, Boolean) AcceptMessageSessionAsync(String, Boolean) AcceptMessageSessionAsync(String, Boolean) AcceptMessageSessionAsync(String, Boolean)
AcceptMessageSessionAsync(String, Boolean, TimeSpan) AcceptMessageSessionAsync(String, Boolean, TimeSpan) AcceptMessageSessionAsync(String, Boolean, TimeSpan) AcceptMessageSessionAsync(String, Boolean, TimeSpan) AcceptMessageSessionAsync(String, Boolean, TimeSpan) AcceptMessageSessionAsync(String, Boolean, TimeSpan)
AcceptMessageSessionAsync(String, Guid) AcceptMessageSessionAsync(String, Guid) AcceptMessageSessionAsync(String, Guid) AcceptMessageSessionAsync(String, Guid) AcceptMessageSessionAsync(String, Guid) AcceptMessageSessionAsync(String, Guid)
AcceptMessageSessionAsync(String, Guid, TimeSpan) AcceptMessageSessionAsync(String, Guid, TimeSpan) AcceptMessageSessionAsync(String, Guid, TimeSpan) AcceptMessageSessionAsync(String, Guid, TimeSpan) AcceptMessageSessionAsync(String, Guid, TimeSpan) AcceptMessageSessionAsync(String, Guid, TimeSpan)
AcceptMessageSessionAsync(String, TimeSpan) AcceptMessageSessionAsync(String, TimeSpan) AcceptMessageSessionAsync(String, TimeSpan) AcceptMessageSessionAsync(String, TimeSpan) AcceptMessageSessionAsync(String, TimeSpan) AcceptMessageSessionAsync(String, TimeSpan)

Asynchronously accepts a message session that allows grouping of related messages for processing in a single transaction using the specified server wait time.
AcceptMessageSessionAsync(TimeSpan) AcceptMessageSessionAsync(TimeSpan) AcceptMessageSessionAsync(TimeSpan) AcceptMessageSessionAsync(TimeSpan) AcceptMessageSessionAsync(TimeSpan) AcceptMessageSessionAsync(TimeSpan)

Asynchronously accepts a message session that allows grouping of related messages for processing in a single transaction using the specified server wait time.
AddRule(RuleDescription) AddRule(RuleDescription) AddRule(RuleDescription) AddRule(RuleDescription) AddRule(RuleDescription) AddRule(RuleDescription)

Adds a new rule to the SubscriptionDescription using the specified rule description.
AddRule(String, Filter) AddRule(String, Filter) AddRule(String, Filter) AddRule(String, Filter) AddRule(String, Filter) AddRule(String, Filter)

Adds a rule to the current subscription with the specified name and filter expression.
AddRuleAsync(RuleDescription) AddRuleAsync(RuleDescription) AddRuleAsync(RuleDescription) AddRuleAsync(RuleDescription) AddRuleAsync(RuleDescription) AddRuleAsync(RuleDescription)

Asynchronously adds a new rule to the SubscriptionDescription using the specified rule description.
AddRuleAsync(String, Filter) AddRuleAsync(String, Filter) AddRuleAsync(String, Filter) AddRuleAsync(String, Filter) AddRuleAsync(String, Filter) AddRuleAsync(String, Filter)

Asynchronously adds a rule to the current subscription with the specified name and filter expression.
Close() Close() Close() Close() Close() Close()

Sends a cleanup message to Service Bus to signal the completion of the usage of an entity.

(Inherited from ClientEntity)
CloseAsync() CloseAsync() CloseAsync() CloseAsync() CloseAsync() CloseAsync()

Sends a cleanup message asynchronously to Service Bus to signal the completion of the usage of an entity.

(Inherited from ClientEntity)
Complete(Guid) Complete(Guid) Complete(Guid) Complete(Guid) Complete(Guid) Complete(Guid)

Completes processing of a message.
CompleteAsync(Guid) CompleteAsync(Guid) CompleteAsync(Guid) CompleteAsync(Guid) CompleteAsync(Guid) CompleteAsync(Guid)

Asynchronously completes processing of a message.
CompleteBatch(IEnumerable<Guid>) CompleteBatch(IEnumerable<Guid>) CompleteBatch(IEnumerable<Guid>) CompleteBatch(IEnumerable<Guid>) CompleteBatch(IEnumerable<Guid>) CompleteBatch(IEnumerable<Guid>)

Completes processing of a batch.
CompleteBatchAsync(IEnumerable<Guid>) CompleteBatchAsync(IEnumerable<Guid>) CompleteBatchAsync(IEnumerable<Guid>) CompleteBatchAsync(IEnumerable<Guid>) CompleteBatchAsync(IEnumerable<Guid>) CompleteBatchAsync(IEnumerable<Guid>)

Asynchronously completes processing of a batch.
Create(String, String) Create(String, String) Create(String, String) Create(String, String) Create(String, String) Create(String, String)

Creates a new copy of SubscriptionClient with specified name and topic path.
Create(String, String, ReceiveMode) Create(String, String, ReceiveMode) Create(String, String, ReceiveMode) Create(String, String, ReceiveMode) Create(String, String, ReceiveMode) Create(String, String, ReceiveMode)

Creates a new copy of SubscriptionClient with specified name, topic path and mode.
Create(Uri, String, String, AuthenticationContext, ClientAssertionCertificate, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, ClientAssertionCertificate, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, ClientAssertionCertificate, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, ClientAssertionCertificate, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, ClientAssertionCertificate, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, ClientAssertionCertificate, ReceiveMode, Nullable<TimeSpan>, TransportType)

Creates a new instance of the SubscriptionClient by using Azure Active Directory authentication context.
Create(Uri, String, String, AuthenticationContext, ClientCredential, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, ClientCredential, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, ClientCredential, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, ClientCredential, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, ClientCredential, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, ClientCredential, ReceiveMode, Nullable<TimeSpan>, TransportType)

Creates a new instance of the SubscriptionClient by using Azure Active Directory authentication context.
Create(Uri, String, String, AuthenticationContext, String, Uri, IPlatformParameters, UserIdentifier, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, String, Uri, IPlatformParameters, UserIdentifier, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, String, Uri, IPlatformParameters, UserIdentifier, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, String, Uri, IPlatformParameters, UserIdentifier, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, String, Uri, IPlatformParameters, UserIdentifier, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, String, Uri, IPlatformParameters, UserIdentifier, ReceiveMode, Nullable<TimeSpan>, TransportType)

Creates a new instance of the SubscriptionClient by using Azure Active Directory authentication context.
Create(Uri, String, String, AuthenticationContext, String, UserPasswordCredential, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, String, UserPasswordCredential, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, String, UserPasswordCredential, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, String, UserPasswordCredential, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, String, UserPasswordCredential, ReceiveMode, Nullable<TimeSpan>, TransportType) Create(Uri, String, String, AuthenticationContext, String, UserPasswordCredential, ReceiveMode, Nullable<TimeSpan>, TransportType)

Creates a new instance of the SubscriptionClient by using Azure Active Directory authentication context.
CreateFromConnectionString(String, String, String) CreateFromConnectionString(String, String, String) CreateFromConnectionString(String, String, String) CreateFromConnectionString(String, String, String) CreateFromConnectionString(String, String, String) CreateFromConnectionString(String, String, String)

Creates a new copy of SubscriptionClient from a connection string with specified topic path and name.
CreateFromConnectionString(String, String, String, ReceiveMode) CreateFromConnectionString(String, String, String, ReceiveMode) CreateFromConnectionString(String, String, String, ReceiveMode) CreateFromConnectionString(String, String, String, ReceiveMode) CreateFromConnectionString(String, String, String, ReceiveMode) CreateFromConnectionString(String, String, String, ReceiveMode)

Creates a new copy of SubscriptionClient from a connection string with specified topic path, name and mode.
CreateWithManagedServiceIdentity(Uri, String, String, ReceiveMode, Nullable<TimeSpan>, TransportType) CreateWithManagedServiceIdentity(Uri, String, String, ReceiveMode, Nullable<TimeSpan>, TransportType) CreateWithManagedServiceIdentity(Uri, String, String, ReceiveMode, Nullable<TimeSpan>, TransportType) CreateWithManagedServiceIdentity(Uri, String, String, ReceiveMode, Nullable<TimeSpan>, TransportType) CreateWithManagedServiceIdentity(Uri, String, String, ReceiveMode, Nullable<TimeSpan>, TransportType) CreateWithManagedServiceIdentity(Uri, String, String, ReceiveMode, Nullable<TimeSpan>, TransportType)

Creates a new instance of the SubscriptionClient by using Azure Managed Service Identity authentication.
DeadLetter(Guid) DeadLetter(Guid) DeadLetter(Guid) DeadLetter(Guid) DeadLetter(Guid) DeadLetter(Guid)

Moves the undelivered message to the dead letter queue.
DeadLetter(Guid, IDictionary<String,Object>) DeadLetter(Guid, IDictionary<String,Object>) DeadLetter(Guid, IDictionary<String,Object>) DeadLetter(Guid, IDictionary<String,Object>) DeadLetter(Guid, IDictionary<String,Object>) DeadLetter(Guid, IDictionary<String,Object>)

Moves the undelivered message to the dead letter queue.
DeadLetter(Guid, String, String) DeadLetter(Guid, String, String) DeadLetter(Guid, String, String) DeadLetter(Guid, String, String) DeadLetter(Guid, String, String) DeadLetter(Guid, String, String)

Moves the undelivered message to the dead letter queue.
DeadLetterAsync(Guid) DeadLetterAsync(Guid) DeadLetterAsync(Guid) DeadLetterAsync(Guid) DeadLetterAsync(Guid) DeadLetterAsync(Guid)

Asynchronously moves the undelivered message to the dead letter queue.
DeadLetterAsync(Guid, IDictionary<String,Object>) DeadLetterAsync(Guid, IDictionary<String,Object>) DeadLetterAsync(Guid, IDictionary<String,Object>) DeadLetterAsync(Guid, IDictionary<String,Object>) DeadLetterAsync(Guid, IDictionary<String,Object>) DeadLetterAsync(Guid, IDictionary<String,Object>)

Asynchronously moves the undelivered message to the dead letter queue.
DeadLetterAsync(Guid, String, String) DeadLetterAsync(Guid, String, String) DeadLetterAsync(Guid, String, String) DeadLetterAsync(Guid, String, String) DeadLetterAsync(Guid, String, String) DeadLetterAsync(Guid, String, String)

Asynchronously moves the undelivered message to the dead letter queue.
Defer(Guid) Defer(Guid) Defer(Guid) Defer(Guid) Defer(Guid) Defer(Guid)

Suspends the processing of a message.
Defer(Guid, IDictionary<String,Object>) Defer(Guid, IDictionary<String,Object>) Defer(Guid, IDictionary<String,Object>) Defer(Guid, IDictionary<String,Object>) Defer(Guid, IDictionary<String,Object>) Defer(Guid, IDictionary<String,Object>)

Suspends the processing of a message.
DeferAsync(Guid) DeferAsync(Guid) DeferAsync(Guid) DeferAsync(Guid) DeferAsync(Guid) DeferAsync(Guid)

Asynchronously suspends the processing of a message.
DeferAsync(Guid, IDictionary<String,Object>) DeferAsync(Guid, IDictionary<String,Object>) DeferAsync(Guid, IDictionary<String,Object>) DeferAsync(Guid, IDictionary<String,Object>) DeferAsync(Guid, IDictionary<String,Object>) DeferAsync(Guid, IDictionary<String,Object>)

Asynchronously suspends the processing of a message.
Fault() Fault() Fault() Fault() Fault() Fault()

For internal use only. Do not inherit from this class.

(Inherited from ClientEntity)
FormatDeadLetterPath(String, String) FormatDeadLetterPath(String, String) FormatDeadLetterPath(String, String) FormatDeadLetterPath(String, String) FormatDeadLetterPath(String, String) FormatDeadLetterPath(String, String)

Builds a format name deadletter path using the specified topic path and subscription name.
FormatSubscriptionPath(String, String) FormatSubscriptionPath(String, String) FormatSubscriptionPath(String, String) FormatSubscriptionPath(String, String) FormatSubscriptionPath(String, String) FormatSubscriptionPath(String, String)

Builds a format name subscription path using the specified topic path and subscription name.
GetMessageSessions() GetMessageSessions() GetMessageSessions() GetMessageSessions() GetMessageSessions() GetMessageSessions()

Gets a message session that allows grouping of related messages for processing in a single transaction.
GetMessageSessions(DateTime) GetMessageSessions(DateTime) GetMessageSessions(DateTime) GetMessageSessions(DateTime) GetMessageSessions(DateTime) GetMessageSessions(DateTime)

Retrieves all message sessions whose session state was updated since lastUpdatedTime.
GetMessageSessionsAsync() GetMessageSessionsAsync() GetMessageSessionsAsync() GetMessageSessionsAsync() GetMessageSessionsAsync() GetMessageSessionsAsync()

Asynchronously gets a message session that allows grouping of related messages for processing in a single transaction.
GetMessageSessionsAsync(DateTime) GetMessageSessionsAsync(DateTime) GetMessageSessionsAsync(DateTime) GetMessageSessionsAsync(DateTime) GetMessageSessionsAsync(DateTime) GetMessageSessionsAsync(DateTime)

Asynchronously gets a message session that allows grouping of related messages for processing in a single transaction.
OnAbort() OnAbort() OnAbort() OnAbort() OnAbort() OnAbort()

Executes the abort action.
OnBeginAcceptMessageSession(String, ReceiveMode, Boolean, Nullable<Guid>, TimeSpan, TimeSpan, AsyncCallback, Object) OnBeginAcceptMessageSession(String, ReceiveMode, Boolean, Nullable<Guid>, TimeSpan, TimeSpan, AsyncCallback, Object) OnBeginAcceptMessageSession(String, ReceiveMode, Boolean, Nullable<Guid>, TimeSpan, TimeSpan, AsyncCallback, Object) OnBeginAcceptMessageSession(String, ReceiveMode, Boolean, Nullable<Guid>, TimeSpan, TimeSpan, AsyncCallback, Object) OnBeginAcceptMessageSession(String, ReceiveMode, Boolean, Nullable<Guid>, TimeSpan, TimeSpan, AsyncCallback, Object) OnBeginAcceptMessageSession(String, ReceiveMode, Boolean, Nullable<Guid>, TimeSpan, TimeSpan, AsyncCallback, Object)

Executes upon calling the BeginAcceptMessageSession operation.
OnBeginAddRule(RuleDescription, TimeSpan, AsyncCallback, Object) OnBeginAddRule(RuleDescription, TimeSpan, AsyncCallback, Object) OnBeginAddRule(RuleDescription, TimeSpan, AsyncCallback, Object) OnBeginAddRule(RuleDescription, TimeSpan, AsyncCallback, Object) OnBeginAddRule(RuleDescription, TimeSpan, AsyncCallback, Object) OnBeginAddRule(RuleDescription, TimeSpan, AsyncCallback, Object)

Executes upon calling the BeginAddRule operation.
OnBeginClose(TimeSpan, AsyncCallback, Object) OnBeginClose(TimeSpan, AsyncCallback, Object) OnBeginClose(TimeSpan, AsyncCallback, Object) OnBeginClose(TimeSpan, AsyncCallback, Object) OnBeginClose(TimeSpan, AsyncCallback, Object) OnBeginClose(TimeSpan, AsyncCallback, Object)

Executes the begin close action.
OnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object) OnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object) OnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object) OnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object) OnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object) OnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)

Executes the begin create receiver action.
OnBeginCreateReceiver(String, String, ReceiveMode, TimeSpan, AsyncCallback, Object) OnBeginCreateReceiver(String, String, ReceiveMode, TimeSpan, AsyncCallback, Object) OnBeginCreateReceiver(String, String, ReceiveMode, TimeSpan, AsyncCallback, Object) OnBeginCreateReceiver(String, String, ReceiveMode, TimeSpan, AsyncCallback, Object) OnBeginCreateReceiver(String, String, ReceiveMode, TimeSpan, AsyncCallback, Object) OnBeginCreateReceiver(String, String, ReceiveMode, TimeSpan, AsyncCallback, Object)

Executes the begin create receiver action.
OnBeginGetMessageSessions(DateTime, AsyncCallback, Object) OnBeginGetMessageSessions(DateTime, AsyncCallback, Object) OnBeginGetMessageSessions(DateTime, AsyncCallback, Object) OnBeginGetMessageSessions(DateTime, AsyncCallback, Object) OnBeginGetMessageSessions(DateTime, AsyncCallback, Object) OnBeginGetMessageSessions(DateTime, AsyncCallback, Object)

Executes upon calling the BeginGetMessageSessions operation.
OnBeginGetRules(Int32, Int32, TimeSpan, AsyncCallback, Object) OnBeginGetRules(Int32, Int32, TimeSpan, AsyncCallback, Object) OnBeginGetRules(Int32, Int32, TimeSpan, AsyncCallback, Object) OnBeginGetRules(Int32, Int32, TimeSpan, AsyncCallback, Object) OnBeginGetRules(Int32, Int32, TimeSpan, AsyncCallback, Object) OnBeginGetRules(Int32, Int32, TimeSpan, AsyncCallback, Object)
OnBeginOpen(TimeSpan, AsyncCallback, Object) OnBeginOpen(TimeSpan, AsyncCallback, Object) OnBeginOpen(TimeSpan, AsyncCallback, Object) OnBeginOpen(TimeSpan, AsyncCallback, Object) OnBeginOpen(TimeSpan, AsyncCallback, Object) OnBeginOpen(TimeSpan, AsyncCallback, Object) Inherited from ClientEntity
OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object) OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object) OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object) OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object) OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object) OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object)

Begins removing a RuleDescription from a SubscriptionDescription through the run-time client protocol.
OnBeginRemoveRulesByTag(String, TimeSpan, AsyncCallback, Object) OnBeginRemoveRulesByTag(String, TimeSpan, AsyncCallback, Object) OnBeginRemoveRulesByTag(String, TimeSpan, AsyncCallback, Object) OnBeginRemoveRulesByTag(String, TimeSpan, AsyncCallback, Object) OnBeginRemoveRulesByTag(String, TimeSpan, AsyncCallback, Object) OnBeginRemoveRulesByTag(String, TimeSpan, AsyncCallback, Object)

Begins removing a RuleDescription from a SubscriptionDescription through the run-time client protocol using a tag.
OnClose(TimeSpan) OnClose(TimeSpan) OnClose(TimeSpan) OnClose(TimeSpan) OnClose(TimeSpan) OnClose(TimeSpan)

Executes the close action.
OnClosed() OnClosed() OnClosed() OnClosed() OnClosed() OnClosed() Inherited from ClientEntity
OnEndAcceptMessageSession(IAsyncResult) OnEndAcceptMessageSession(IAsyncResult) OnEndAcceptMessageSession(IAsyncResult) OnEndAcceptMessageSession(IAsyncResult) OnEndAcceptMessageSession(IAsyncResult) OnEndAcceptMessageSession(IAsyncResult)

Executes upon calling the EndAcceptMessageSession operation.
OnEndAddRule(IAsyncResult) OnEndAddRule(IAsyncResult) OnEndAddRule(IAsyncResult) OnEndAddRule(IAsyncResult) OnEndAddRule(IAsyncResult) OnEndAddRule(IAsyncResult)

Ends the asynchronous call to OnBeginAddRule(RuleDescription, TimeSpan, AsyncCallback, Object).
OnEndClose(IAsyncResult) OnEndClose(IAsyncResult) OnEndClose(IAsyncResult) OnEndClose(IAsyncResult) OnEndClose(IAsyncResult) OnEndClose(IAsyncResult)

Executes the end close action.
OnEndCreateReceiver(IAsyncResult) OnEndCreateReceiver(IAsyncResult) OnEndCreateReceiver(IAsyncResult) OnEndCreateReceiver(IAsyncResult) OnEndCreateReceiver(IAsyncResult) OnEndCreateReceiver(IAsyncResult)

Executes the end create receiver action.
OnEndGetMessageSessions(IAsyncResult) OnEndGetMessageSessions(IAsyncResult) OnEndGetMessageSessions(IAsyncResult) OnEndGetMessageSessions(IAsyncResult) OnEndGetMessageSessions(IAsyncResult) OnEndGetMessageSessions(IAsyncResult)

Executes the end get message action.
OnEndGetRules(IAsyncResult) OnEndGetRules(IAsyncResult) OnEndGetRules(IAsyncResult) OnEndGetRules(IAsyncResult) OnEndGetRules(IAsyncResult) OnEndGetRules(IAsyncResult)
OnEndOpen(IAsyncResult) OnEndOpen(IAsyncResult) OnEndOpen(IAsyncResult) OnEndOpen(IAsyncResult) OnEndOpen(IAsyncResult) OnEndOpen(IAsyncResult) Inherited from ClientEntity
OnEndRemoveRule(IAsyncResult) OnEndRemoveRule(IAsyncResult) OnEndRemoveRule(IAsyncResult) OnEndRemoveRule(IAsyncResult) OnEndRemoveRule(IAsyncResult) OnEndRemoveRule(IAsyncResult)

Ends the asynchronous call to OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object).
OnEndRemoveRules(IAsyncResult) OnEndRemoveRules(IAsyncResult) OnEndRemoveRules(IAsyncResult) OnEndRemoveRules(IAsyncResult) OnEndRemoveRules(IAsyncResult) OnEndRemoveRules(IAsyncResult)

Ends the asynchronous call to OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object).
OnFaulted() OnFaulted() OnFaulted() OnFaulted() OnFaulted() OnFaulted() Inherited from ClientEntity
OnMessage(Action<BrokeredMessage>) OnMessage(Action<BrokeredMessage>) OnMessage(Action<BrokeredMessage>) OnMessage(Action<BrokeredMessage>) OnMessage(Action<BrokeredMessage>) OnMessage(Action<BrokeredMessage>)

Processes a message in an event-driven message pump.
OnMessage(Action<BrokeredMessage>, OnMessageOptions) OnMessage(Action<BrokeredMessage>, OnMessageOptions) OnMessage(Action<BrokeredMessage>, OnMessageOptions) OnMessage(Action<BrokeredMessage>, OnMessageOptions) OnMessage(Action<BrokeredMessage>, OnMessageOptions) OnMessage(Action<BrokeredMessage>, OnMessageOptions)

Processes a message in an event-driven message pump, with the given set of OnMessageOptions options.
OnMessageAsync(Func<BrokeredMessage,Task>) OnMessageAsync(Func<BrokeredMessage,Task>) OnMessageAsync(Func<BrokeredMessage,Task>) OnMessageAsync(Func<BrokeredMessage,Task>) OnMessageAsync(Func<BrokeredMessage,Task>) OnMessageAsync(Func<BrokeredMessage,Task>)

Asynchronously processes a message.
OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions) OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions) OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions) OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions) OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions) OnMessageAsync(Func<BrokeredMessage,Task>, OnMessageOptions)

Asynchronously processes a message.
OnOpen(TimeSpan) OnOpen(TimeSpan) OnOpen(TimeSpan) OnOpen(TimeSpan) OnOpen(TimeSpan) OnOpen(TimeSpan) Inherited from ClientEntity
OnOpened() OnOpened() OnOpened() OnOpened() OnOpened() OnOpened() Inherited from ClientEntity
Peek() Peek() Peek() Peek() Peek() Peek()

Returns without removing the first message in the queue.
Peek(Int64) Peek(Int64) Peek(Int64) Peek(Int64) Peek(Int64) Peek(Int64)

Returns without removing the first message in the queue.
PeekAsync() PeekAsync() PeekAsync() PeekAsync() PeekAsync() PeekAsync()

Asynchronously returns without removing the first message in the queue.
PeekAsync(Int64) PeekAsync(Int64) PeekAsync(Int64) PeekAsync(Int64) PeekAsync(Int64) PeekAsync(Int64)

Asynchronously returns without removing the first message in the queue.
PeekBatch(Int32) PeekBatch(Int32) PeekBatch(Int32) PeekBatch(Int32) PeekBatch(Int32) PeekBatch(Int32)

Returns without removing the first messages in a batch.
PeekBatch(Int64, Int32) PeekBatch(Int64, Int32) PeekBatch(Int64, Int32) PeekBatch(Int64, Int32) PeekBatch(Int64, Int32) PeekBatch(Int64, Int32)

Returns without removing the first messages in a batch.
PeekBatchAsync(Int32) PeekBatchAsync(Int32) PeekBatchAsync(Int32) PeekBatchAsync(Int32) PeekBatchAsync(Int32) PeekBatchAsync(Int32)

Asynchronously returns without removing the first messages in a batch.
PeekBatchAsync(Int64, Int32) PeekBatchAsync(Int64, Int32) PeekBatchAsync(Int64, Int32) PeekBatchAsync(Int64, Int32) PeekBatchAsync(Int64, Int32) PeekBatchAsync(Int64, Int32)

Asynchronously returns without removing the first messages in a batch.
Receive() Receive() Receive() Receive() Receive() Receive()

Receives a message using the Microsoft.ServiceBus.Messaging.SubscriptionClient.InternalReceiver.
Receive(Int64) Receive(Int64) Receive(Int64) Receive(Int64) Receive(Int64) Receive(Int64)

Receives a message using the Microsoft.ServiceBus.Messaging.SubscriptionClient.InternalReceiver.
Receive(TimeSpan) Receive(TimeSpan) Receive(TimeSpan) Receive(TimeSpan) Receive(TimeSpan) Receive(TimeSpan)

Receives a message using the Microsoft.ServiceBus.Messaging.SubscriptionClient.InternalReceiver.
ReceiveAsync() ReceiveAsync() ReceiveAsync() ReceiveAsync() ReceiveAsync() ReceiveAsync()

Asynchronously receives a message using the Microsoft.ServiceBus.Messaging.SubscriptionClient.InternalReceiver.
ReceiveAsync(Int64) ReceiveAsync(Int64) ReceiveAsync(Int64) ReceiveAsync(Int64) ReceiveAsync(Int64) ReceiveAsync(Int64)

Asynchronously receives a message using the Microsoft.ServiceBus.Messaging.SubscriptionClient.InternalReceiver.
ReceiveAsync(TimeSpan) ReceiveAsync(TimeSpan) ReceiveAsync(TimeSpan) ReceiveAsync(TimeSpan) ReceiveAsync(TimeSpan) ReceiveAsync(TimeSpan)

Asynchronously receives a message using the Microsoft.ServiceBus.Messaging.SubscriptionClient.InternalReceiver.
ReceiveBatch(IEnumerable<Int64>) ReceiveBatch(IEnumerable<Int64>) ReceiveBatch(IEnumerable<Int64>) ReceiveBatch(IEnumerable<Int64>) ReceiveBatch(IEnumerable<Int64>) ReceiveBatch(IEnumerable<Int64>)

Receives a batch after the asynchronous operation.
ReceiveBatch(Int32) ReceiveBatch(Int32) ReceiveBatch(Int32) ReceiveBatch(Int32) ReceiveBatch(Int32) ReceiveBatch(Int32)

Receives a batch after the asynchronous operation.
ReceiveBatch(Int32, TimeSpan) ReceiveBatch(Int32, TimeSpan) ReceiveBatch(Int32, TimeSpan) ReceiveBatch(Int32, TimeSpan) ReceiveBatch(Int32, TimeSpan) ReceiveBatch(Int32, TimeSpan)

Receives a batch after the asynchronous operation.
ReceiveBatchAsync(IEnumerable<Int64>) ReceiveBatchAsync(IEnumerable<Int64>) ReceiveBatchAsync(IEnumerable<Int64>) ReceiveBatchAsync(IEnumerable<Int64>) ReceiveBatchAsync(IEnumerable<Int64>) ReceiveBatchAsync(IEnumerable<Int64>)

Asynchronously receives a set of messages (for batch processing).
ReceiveBatchAsync(Int32) ReceiveBatchAsync(Int32) ReceiveBatchAsync(Int32) ReceiveBatchAsync(Int32) ReceiveBatchAsync(Int32) ReceiveBatchAsync(Int32)

Asynchronously receives a set of messages (for batch processing).
ReceiveBatchAsync(Int32, TimeSpan) ReceiveBatchAsync(Int32, TimeSpan) ReceiveBatchAsync(Int32, TimeSpan) ReceiveBatchAsync(Int32, TimeSpan) ReceiveBatchAsync(Int32, TimeSpan) ReceiveBatchAsync(Int32, TimeSpan)

Asynchronously receives a set of messages (for batch processing).
RegisterSessionHandler(Type) RegisterSessionHandler(Type) RegisterSessionHandler(Type) RegisterSessionHandler(Type) RegisterSessionHandler(Type) RegisterSessionHandler(Type)

Registers the handler for the client session.
RegisterSessionHandler(Type, SessionHandlerOptions) RegisterSessionHandler(Type, SessionHandlerOptions) RegisterSessionHandler(Type, SessionHandlerOptions) RegisterSessionHandler(Type, SessionHandlerOptions) RegisterSessionHandler(Type, SessionHandlerOptions) RegisterSessionHandler(Type, SessionHandlerOptions)

Registers the handler for the client session.
RegisterSessionHandlerAsync(Type) RegisterSessionHandlerAsync(Type) RegisterSessionHandlerAsync(Type) RegisterSessionHandlerAsync(Type) RegisterSessionHandlerAsync(Type) RegisterSessionHandlerAsync(Type)

Asynchronously registers the handler for the client session.
RegisterSessionHandlerAsync(Type, SessionHandlerOptions) RegisterSessionHandlerAsync(Type, SessionHandlerOptions) RegisterSessionHandlerAsync(Type, SessionHandlerOptions) RegisterSessionHandlerAsync(Type, SessionHandlerOptions) RegisterSessionHandlerAsync(Type, SessionHandlerOptions) RegisterSessionHandlerAsync(Type, SessionHandlerOptions)

Asynchronously registers the handler for the client session.
RegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)

Registers the handler factory for the client session.
RegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)

Registers the handler factory for the client session.
RegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)

Asynchronously registers the handler factory for the client session.
RegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions) RegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)

Asynchronously registers the handler factory for the client session.
RemoveRule(String) RemoveRule(String) RemoveRule(String) RemoveRule(String) RemoveRule(String) RemoveRule(String)

Removes the rule described by ruleName.
RemoveRuleAsync(String) RemoveRuleAsync(String) RemoveRuleAsync(String) RemoveRuleAsync(String) RemoveRuleAsync(String) RemoveRuleAsync(String)

Asynchronously removes the rule described by ruleName.
RenewMessageLock(Guid) RenewMessageLock(Guid) RenewMessageLock(Guid) RenewMessageLock(Guid) RenewMessageLock(Guid) RenewMessageLock(Guid)
RenewMessageLockAsync(Guid) RenewMessageLockAsync(Guid) RenewMessageLockAsync(Guid) RenewMessageLockAsync(Guid) RenewMessageLockAsync(Guid) RenewMessageLockAsync(Guid)
ThrowIfClosed() ThrowIfClosed() ThrowIfClosed() ThrowIfClosed() ThrowIfClosed() ThrowIfClosed() Inherited from ClientEntity
ThrowIfDisposed() ThrowIfDisposed() ThrowIfDisposed() ThrowIfDisposed() ThrowIfDisposed() ThrowIfDisposed() Inherited from ClientEntity
ThrowIfDisposedOrImmutable() ThrowIfDisposedOrImmutable() ThrowIfDisposedOrImmutable() ThrowIfDisposedOrImmutable() ThrowIfDisposedOrImmutable() ThrowIfDisposedOrImmutable() Inherited from ClientEntity
ThrowIfDisposedOrNotOpen() ThrowIfDisposedOrNotOpen() ThrowIfDisposedOrNotOpen() ThrowIfDisposedOrNotOpen() ThrowIfDisposedOrNotOpen() ThrowIfDisposedOrNotOpen() Inherited from ClientEntity
ThrowIfFaulted() ThrowIfFaulted() ThrowIfFaulted() ThrowIfFaulted() ThrowIfFaulted() ThrowIfFaulted() Inherited from ClientEntity

Extension Methods

IsDefined(Object) IsDefined(Object) IsDefined(Object) IsDefined(Object) IsDefined(Object) IsDefined(Object)

Determines if a certain property is defined or not.
IsNull(Object) IsNull(Object) IsNull(Object) IsNull(Object) IsNull(Object) IsNull(Object)

Determines if a certain property is null or not.
IsPrimitive(Object) IsPrimitive(Object) IsPrimitive(Object) IsPrimitive(Object) IsPrimitive(Object) IsPrimitive(Object)

Determines if a certain property is of premitive JSON type.

Applies to