銷售: 1-800-867-1380

SubscriptionClient 類別

代表用於與主題訂閱相關之執行階段作業的錨點類別。

命名空間:  Microsoft.ServiceBus.Messaging
組件:  Microsoft.ServiceBus (在 Microsoft.ServiceBus.dll 中)

public abstract class SubscriptionClient : MessageClientEntity

SubscriptionClient 型別公開下列成員。

  名稱說明
公用屬性IsClosed (繼承自 ClientEntity。)
公用屬性MessagingFactory取得用來建立此訂閱用戶端的傳訊處理站。
公用屬性Mode取得處理接收到訊息時的訊息接收模式。
公用屬性Name取得訂閱的名稱。
公用屬性PrefetchCount取得或設定訊息接收者可以同時要求的訊息數目。
公用屬性RetryPolicy (繼承自 ClientEntity。)
受保護的屬性ThisLock (繼承自 ClientEntity。)
公用屬性TopicPath取得主題的完整路徑名稱。
上層

  名稱說明
公用方法Abandon(Guid)捨棄訊息和交出訊息鎖定擁有權。
公用方法Abandon(Guid, IDictionary<(Of <<'(String, Object>)>>))捨棄訊息和交出訊息鎖定擁有權。
公用方法AbandonAsync(Guid)非同步捨棄訊息和交出訊息鎖定擁有權。
公用方法AbandonAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))非同步捨棄訊息和交出訊息鎖定擁有權。
公用方法AbortPerforms abort functionality on the messaging entity. (繼承自 ClientEntity。)
公用方法AcceptMessageSession()()()()接受訊息工作階段,此訊息工作階段允許將要在單一交易中處理的相關訊息群組在一起。
公用方法AcceptMessageSession(String)接受訊息工作階段,此訊息工作階段允許使用指定的工作階段識別碼,將要在單一交易中處理的相關訊息群組在一起。
公用方法AcceptMessageSession(TimeSpan)接受訊息工作階段,此訊息工作階段允許使用指定的伺服器等待時間,將要在單一交易中處理的相關訊息群組在一起。
公用方法AcceptMessageSession(String, TimeSpan)接受訊息工作階段,此訊息工作階段允許使用指定的工作階段識別碼和等待時間,將要在單一交易中處理的相關訊息群組在一起。
公用方法AcceptMessageSessionAsync()()()()非同步接受訊息工作階段,此訊息工作階段允許使用指定的伺服器等待時間,將要在單一交易中處理的相關訊息群組在一起。
公用方法AcceptMessageSessionAsync(String)非同步接受訊息工作階段,此訊息工作階段允許使用指定的伺服器等待時間,將要在單一交易中處理的相關訊息群組在一起。
公用方法AcceptMessageSessionAsync(TimeSpan)非同步接受訊息工作階段,此訊息工作階段允許使用指定的伺服器等待時間,將要在單一交易中處理的相關訊息群組在一起。
公用方法AcceptMessageSessionAsync(String, TimeSpan)非同步接受訊息工作階段,此訊息工作階段允許使用指定的伺服器等待時間,將要在單一交易中處理的相關訊息群組在一起。
公用方法AddRule(RuleDescription)使用指定的規則描述,將新規則新增至 Subscription
公用方法AddRule(String, Filter)使用指定的名稱和篩選運算式,將規則新增至目前訂閱。
公用方法AddRuleAsync(RuleDescription)使用指定的規則描述,將新規則非同步新增至 Subscription
公用方法AddRuleAsync(String, Filter)使用指定的名稱和篩選運算式,將規則非同步新增至目前訂閱。
公用方法BeginAbandon(Guid, AsyncCallback, Object)開始放棄訊息並交出其鎖定的非同步作業。
公用方法BeginAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)開始放棄訊息並交出其鎖定的非同步作業。
公用方法BeginAcceptMessageSession(AsyncCallback, Object)開始要接受訊息工作階段的非同步作業。
公用方法BeginAcceptMessageSession(String, AsyncCallback, Object)開始要接受訊息工作階段的非同步作業。
公用方法BeginAcceptMessageSession(TimeSpan, AsyncCallback, Object)開始要接受訊息工作階段的非同步作業。
公用方法BeginAcceptMessageSession(String, TimeSpan, AsyncCallback, Object)開始要接受訊息工作階段的非同步作業。
公用方法BeginAddRule(RuleDescription, AsyncCallback, Object)開始將新規則新增至訂閱的非同步作業。
公用方法BeginAddRule(String, Filter, AsyncCallback, Object)開始將新規則新增至訂閱的非同步作業。
公用方法BeginClose開始關閉訊息用戶端實體的非同步作業。 (繼承自 MessageClientEntity。)
公用方法BeginComplete開始完成處理訊息的非同步作業。
公用方法BeginCompleteBatch開始完成處理訊息的非同步作業。
公用方法BeginDeadLetter(Guid, AsyncCallback, Object)開始將訊息移至寄不出信件佇列的非同步作業。
公用方法BeginDeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)開始將訊息移至寄不出信件佇列的非同步作業。
公用方法BeginDeadLetter(Guid, String, String, AsyncCallback, Object)開始將訊息移至寄不出信件佇列的非同步作業。
公用方法BeginDefer(Guid, AsyncCallback, Object)開始暫停處理訊息的非同步作業。
公用方法BeginDefer(Guid, IDictionary<(Of <<'(String, Object>)>>), AsyncCallback, Object)開始暫停處理訊息的非同步作業。
公用方法BeginGetMessageSessions(AsyncCallback, Object)開始要取得訊息工作階段的非同步作業。
公用方法BeginGetMessageSessions(DateTime, AsyncCallback, Object)開始要取得訊息工作階段的非同步作業。
公用方法BeginPeek(AsyncCallback, Object)開始傳回而不移除佇列中最初訊息的非同步作業。
公用方法BeginPeek(Int64, AsyncCallback, Object)開始傳回而不移除佇列中最初訊息的非同步作業。
公用方法BeginPeekBatch(Int32, AsyncCallback, Object)查看批次的非同步作業。
公用方法BeginPeekBatch(Int64, Int32, AsyncCallback, Object)查看批次的非同步作業。
公用方法BeginReceive(AsyncCallback, Object)開始接收訊息的非同步作業。
公用方法BeginReceive(Int64, AsyncCallback, Object)開始接收訊息的非同步作業。
公用方法BeginReceive(TimeSpan, AsyncCallback, Object)開始接收訊息的非同步作業。
公用方法BeginReceiveBatch(IEnumerable<(Of <<'(Int64>)>>), AsyncCallback, Object)開始要接收批次的非同步作業。
公用方法BeginReceiveBatch(Int32, AsyncCallback, Object)開始要接收批次的非同步作業。
公用方法BeginReceiveBatch(Int32, TimeSpan, AsyncCallback, Object)開始要接收批次的非同步作業。
公用方法BeginRemoveRule開始非同步移除規則動作。
公用方法CloseSends a cleanup message to Service Bus to signal the completion of the usage of an entity. (繼承自 ClientEntity。)
公用方法CloseAsyncSends a cleanup message asynchronously to Service Bus to signal the completion of the usage of an entity. (繼承自 ClientEntity。)
公用方法Complete完成處理訊息。
公用方法CompleteAsync非同步完成處理訊息。
公用方法CompleteBatch完成批次處理。
公用方法CompleteBatchAsync非同步完成處理批次。
公用方法靜態成員Create(String, String)使用指定的名稱和主題路徑,建立 SubscriptionClient 的新複本。
公用方法靜態成員Create(String, String, ReceiveMode)使用指定的名稱、主題路徑和模式,建立 SubscriptionClient 的新複本。
公用方法靜態成員CreateFromConnectionString(String, String, String)使用指定的主題路徑和名稱,從連線字串建立 SubscriptionClient 的新複本。
公用方法靜態成員CreateFromConnectionString(String, String, String, ReceiveMode)使用指定的主題路徑、名稱和模式,從連線字串建立 SubscriptionClient 的新複本。
公用方法DeadLetter(Guid)將未傳遞的訊息移至寄不出信件的佇列。
公用方法DeadLetter(Guid, IDictionary<(Of <<'(String, Object>)>>))將未傳遞的訊息移至寄不出信件的佇列。
公用方法DeadLetter(Guid, String, String)將未傳遞的訊息移至寄不出信件的佇列。
公用方法DeadLetterAsync(Guid)將未傳遞的訊息非同步移至寄不出信件的佇列。
公用方法DeadLetterAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))將未傳遞的訊息非同步移至寄不出信件的佇列。
公用方法DeadLetterAsync(Guid, String, String)將未傳遞的訊息非同步移至寄不出信件的佇列。
公用方法Defer(Guid)暫停處理訊息。
公用方法Defer(Guid, IDictionary<(Of <<'(String, Object>)>>))暫停處理訊息。
公用方法DeferAsync(Guid)非同步暫停處理訊息。
公用方法DeferAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))非同步暫停處理訊息。
公用方法EndAbandon完成放棄訊息並交出其鎖定的非同步作業。
公用方法EndAcceptMessageSession完成接受訊息工作階段的非同步作業,此訊息工作階段允許將要在單一交易中處理的相關訊息群組在一起。
公用方法EndAddRule結束非同步新增規則作業。
公用方法EndClose完成關閉訊息用戶端實體的非同步作業。 (繼承自 MessageClientEntity。)
公用方法EndComplete完成完成處理訊息的非同步作業。
公用方法EndCompleteBatch完成要完成批次處理的非同步作業。
公用方法EndDeadLetter完成將訊息移至寄不出信件佇列的非同步作業。
公用方法EndDefer完成暫停處理訊息的非同步作業。
公用方法EndGetMessageSessions完成要開始處理訊息的非同步作業。
公用方法EndPeek完成非同步查看作業。
公用方法EndPeekBatch完成一批訊息的非同步查看作業。
公用方法EndReceive完成接收訊息的非同步作業。
公用方法EndReceiveBatch完成要接收批次的非同步作業。
公用方法EndRemoveRule結束非同步移除規則作業。
公用方法Equals (繼承自 Object。)
受保護的方法FaultFor internal use only. Do not inherit from this class. (繼承自 ClientEntity。)
受保護的方法Finalize (繼承自 Object。)
公用方法靜態成員FormatDeadLetterPath使用指定的主題路徑和訂閱名稱,建置格式名稱寄不出信件路徑。
公用方法靜態成員FormatSubscriptionPath使用指定的主題路徑和訂閱名稱,建置格式名稱訂閱路徑。
公用方法GetHashCode (繼承自 Object。)
公用方法GetMessageSessions()()()()取得允許將相關訊息分組以在單一交易中處理的訊息工作階段。
公用方法GetMessageSessions(DateTime)擷取自 lastUpdatedTime 後已更新其工作階段狀態的所有訊息工作階段。
公用方法GetMessageSessionsAsync()()()()非同步取得訊息工作階段,此訊息工作階段允許將要在單一交易中處理的相關訊息群組在一起。
公用方法GetMessageSessionsAsync(DateTime)非同步取得訊息工作階段,此訊息工作階段允許將要在單一交易中處理的相關訊息群組在一起。
公用方法GetType (繼承自 Object。)
受保護的方法MemberwiseClone (繼承自 Object。)
受保護的方法OnAbort執行中止動作。 (覆寫 ClientEntity..::..OnAbort()()()()。)
受保護的方法OnBeginAcceptMessageSession在呼叫 BeginAcceptMessageSession 作業時執行。
受保護的方法OnBeginAddRule在呼叫 BeginAddRule 作業時執行。
受保護的方法OnBeginClose執行開始關閉動作。 (覆寫 ClientEntity..::..OnBeginClose(TimeSpan, AsyncCallback, Object)。)
受保護的方法OnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)執行開始建立接收者動作。
受保護的方法OnBeginCreateReceiver(String, String, ReceiveMode, TimeSpan, AsyncCallback, Object)執行開始建立接收者動作。
受保護的方法OnBeginGetMessageSessions在呼叫 BeginGetMessageSessions 作業時執行。
受保護的方法OnBeginOpen (繼承自 ClientEntity。)
受保護的方法OnBeginRemoveRule透過執行階段用戶端通訊協定,開始從 Rule 移除 Subscription
受保護的方法OnBeginRemoveRulesByTag使用標記透過執行階段用戶端通訊協定,開始從 Rule 移除 Subscription
受保護的方法OnClose執行關閉動作。 (覆寫 ClientEntity..::..OnClose(TimeSpan)。)
受保護的方法OnClosed (繼承自 ClientEntity。)
受保護的方法OnEndAcceptMessageSession在呼叫 EndAcceptMessageSession 作業時執行。
受保護的方法OnEndAddRule結束 OnBeginAddRule 的非同步呼叫。
受保護的方法OnEndClose執行結束關閉動作。 (覆寫 ClientEntity..::..OnEndClose(IAsyncResult)。)
受保護的方法OnEndCreateReceiver執行結束建立接收者動作。
受保護的方法OnEndGetMessageSessions執行結束取得訊息動作。
受保護的方法OnEndOpen (繼承自 ClientEntity。)
受保護的方法OnEndRemoveRule結束 OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object) 的非同步呼叫。
受保護的方法OnEndRemoveRules結束 OnBeginRemoveRule(String, TimeSpan, AsyncCallback, Object) 的非同步呼叫。
受保護的方法OnFaulted (繼承自 ClientEntity。)
公用方法OnMessage(Action<(Of <<'(BrokeredMessage>)>>))處理事件驅動的訊息抽出之中的訊息。
公用方法OnMessage(Action<(Of <<'(BrokeredMessage>)>>), OnMessageOptions)處理事件驅動的訊息抽出之中的訊息,其中有一組指定的 OnMessageOptions 選項。
公用方法OnMessageAsync(Func<(Of <<'(BrokeredMessage, Task>)>>))非同步處理訊息。
公用方法OnMessageAsync(Func<(Of <<'(BrokeredMessage, Task>)>>), OnMessageOptions)非同步處理訊息。
受保護的方法OnOpen (繼承自 ClientEntity。)
受保護的方法OnOpened (繼承自 ClientEntity。)
公用方法Peek()()()()傳回而不移除佇列中的最初訊息。
公用方法Peek(Int64)傳回而不移除佇列中的最初訊息。
公用方法PeekAsync()()()()非同步傳回而不移除佇列中的最初訊息。
公用方法PeekAsync(Int64)非同步傳回而不移除佇列中的最初訊息。
公用方法PeekBatch(Int32)傳回而不移除批次中的最初訊息。
公用方法PeekBatch(Int64, Int32)傳回而不移除批次中的最初訊息。
公用方法PeekBatchAsync(Int32)非同步傳回而不移除批次中的最初訊息。
公用方法PeekBatchAsync(Int64, Int32)非同步傳回而不移除批次中的最初訊息。
公用方法Receive()()()()使用 InternalReceiver()()()() 接收訊息。
公用方法Receive(Int64)使用 InternalReceiver()()()() 接收訊息。
公用方法Receive(TimeSpan)使用 InternalReceiver()()()() 接收訊息。
公用方法ReceiveAsync()()()()使用 InternalReceiver()()()() 非同步接收訊息。
公用方法ReceiveAsync(Int64)使用 InternalReceiver()()()() 非同步接收訊息。
公用方法ReceiveAsync(TimeSpan)使用 InternalReceiver()()()() 非同步接收訊息。
公用方法ReceiveBatch(IEnumerable<(Of <<'(Int64>)>>))在非同步作業後接收批次。
公用方法ReceiveBatch(Int32)在非同步作業後接收批次。
公用方法ReceiveBatch(Int32, TimeSpan)在非同步作業後接收批次。
公用方法ReceiveBatchAsync(IEnumerable<(Of <<'(Int64>)>>))非同步接收一組訊息 (以進行批次處理)。
公用方法ReceiveBatchAsync(Int32)非同步接收一組訊息 (以進行批次處理)。
公用方法ReceiveBatchAsync(Int32, TimeSpan)非同步接收一組訊息 (以進行批次處理)。
公用方法RegisterSessionHandler(Type)註冊用戶端工作階段的處理常式。
公用方法RegisterSessionHandler(Type, SessionHandlerOptions)註冊用戶端工作階段的處理常式。
公用方法RegisterSessionHandlerAsync(Type)以非同步方式註冊用戶端工作階段的處理常式。
公用方法RegisterSessionHandlerAsync(Type, SessionHandlerOptions)以非同步方式註冊用戶端工作階段的處理常式。
公用方法RegisterSessionHandlerFactory(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)註冊用戶端工作階段的處理常式處理站。
公用方法RegisterSessionHandlerFactory(IMessageSessionHandlerFactory, SessionHandlerOptions)註冊用戶端工作階段的處理常式處理站。
公用方法RegisterSessionHandlerFactoryAsync(IMessageSessionAsyncHandlerFactory, SessionHandlerOptions)以非同步方式註冊用戶端工作階段的處理常式處理站。
公用方法RegisterSessionHandlerFactoryAsync(IMessageSessionHandlerFactory, SessionHandlerOptions)以非同步方式註冊用戶端工作階段的處理常式處理站。
公用方法RemoveRule移除 ruleName 所述的規則。
公用方法RemoveRuleAsync非同步移除 ruleName 所述的規則。
受保護的方法ThrowIfClosed (繼承自 ClientEntity。)
受保護的方法ThrowIfDisposed (繼承自 ClientEntity。)
受保護的方法ThrowIfDisposedOrImmutable (繼承自 ClientEntity。)
受保護的方法ThrowIfDisposedOrNotOpen (繼承自 ClientEntity。)
受保護的方法ThrowIfFaulted (繼承自 ClientEntity。)
公用方法ToString (繼承自 Object。)
上層

This abstract class is not meant to be inherited, so protected members of this class should be ignored.

// Create subscription client
SubscriptionClient mySubscriptionClient = 
factory.CreateSubscriptionClient(topicName, subscriptionName);

// Create a receiver
MessageReceiver myMessageReceiver = mySubscriptionClient.CreateReceiver(ReceiveMode.PeekLock);

// Receive messages
for (int count = 0; count &lt; MsgCount; count++)
{
    var message = subscriptionClient.Receive();
    message.Complete();
}

Any public static (Shared in Visual Basic) members of this type are thread safe. Instance members are also guaranteed to be thread safe.

本文對您有任何幫助嗎?
(剩餘 1500 個字元)
感謝您提供意見

社群新增項目

新增
顯示:
© 2014 Microsoft