銷售: 1-800-867-1380

QueueClient 類別

代表佇列用戶端物件。

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

public abstract class QueueClient : MessageClientEntity

QueueClient 型別公開下列成員。

  名稱說明
公用屬性IsClosed (繼承自 ClientEntity。)
公用屬性MessagingFactory取得或設定傳訊處理站。
公用屬性Mode取得處理接收到訊息時的訊息接收模式。
公用屬性Path取得或設定佇列的完整路徑名稱。
公用屬性PrefetchCount取得或設定佇列接收者可以同時要求的訊息數目。
公用屬性RetryPolicy (繼承自 ClientEntity。)
受保護的屬性ThisLock (繼承自 ClientEntity。)
上層

  名稱說明
公用方法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)非同步接受訊息工作階段,此訊息工作階段允許使用指定的工作階段識別碼和等待時間,將要在單一交易中處理的相關訊息群組在一起。
公用方法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)開始要接受訊息工作階段的非同步作業。
公用方法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)開始接收訊息批次的非同步作業。
公用方法BeginSend開始傳送訊息的非同步作業。
公用方法BeginSendBatch開始傳送訊息批次的非同步作業。
公用方法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)使用指定的路徑建立 QueueClient 的新複本。
公用方法靜態成員Create(String, ReceiveMode)使用指定的路徑和模式,建立 QueueClient 的新複本。
公用方法靜態成員CreateFromConnectionString(String, String)使用指定的路徑,從連線字串建立 QueueClient 的新複本。
公用方法靜態成員CreateFromConnectionString(String, String, ReceiveMode)使用指定的路徑和模式,從連線字串建立 QueueClient 的新複本。
公用方法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完成接受訊息工作階段的非同步作業,此訊息工作階段允許將要在單一交易中處理的相關訊息群組在一起。
公用方法EndClose完成關閉訊息用戶端實體的非同步作業。 (繼承自 MessageClientEntity。)
公用方法EndComplete完成完成處理訊息的非同步作業。
公用方法EndCompleteBatch完成完成處理訊息批次的非同步作業。
公用方法EndDeadLetter完成將訊息移至寄不出信件佇列的非同步作業。
公用方法EndDefer完成暫停處理訊息的非同步作業。
公用方法EndGetMessageSessions結束要取得訊息工作階段的非同步作業。
公用方法EndPeek結束查看訊息的非同步作業。
公用方法EndPeekBatch結束要查看一批訊息的非同步作業。
公用方法EndReceive完成接收訊息的非同步作業。
公用方法EndReceiveBatch完成要接收訊息批次的非同步作業。
公用方法EndSend完成傳送訊息的非同步作業。
公用方法EndSendBatch完成傳送訊息批次的非同步作業。
公用方法Equals (繼承自 Object。)
受保護的方法FaultFor internal use only. Do not inherit from this class. (繼承自 ClientEntity。)
受保護的方法Finalize (繼承自 Object。)
公用方法靜態成員FormatDeadLetterPath從指定的寄不出信件佇列路徑建置格式名稱。
公用方法GetHashCode (繼承自 Object。)
公用方法GetMessageSessions()()()()取得訊息工作階段,讓您可以瀏覽佇列上的工作階段。
公用方法GetMessageSessions(DateTime)擷取自 lastUpdatedTime 後已更新其工作階段狀態的所有訊息工作階段。
公用方法GetMessageSessionsAsync()()()()非同步取得訊息工作階段,讓您可以瀏覽佇列上的工作階段。
公用方法GetMessageSessionsAsync(DateTime)非同步擷取自 lastUpdatedTime 後已更新其工作階段狀態的所有訊息工作階段。
公用方法GetType (繼承自 Object。)
受保護的方法MemberwiseClone (繼承自 Object。)
受保護的方法OnAbort在呼叫 Abort 事件時執行。 (覆寫 ClientEntity..::..OnAbort()()()()。)
受保護的方法OnBeginAcceptMessageSession在呼叫 BeginAcceptMessageSession 作業時執行。
受保護的方法OnBeginClose在呼叫 Close 作業時執行。 (覆寫 ClientEntity..::..OnBeginClose(TimeSpan, AsyncCallback, Object)。)
受保護的方法OnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)執行開始建立接收者動作。
受保護的方法OnBeginCreateReceiver(String, ReceiveMode, TimeSpan, AsyncCallback, Object)執行開始建立接收者動作。
受保護的方法OnBeginCreateSender執行開始建立傳送者動作。
受保護的方法OnBeginGetMessageSessions執行 BeginGetMessageSessions 動作。
受保護的方法OnBeginOpen (繼承自 ClientEntity。)
受保護的方法OnClose在呼叫 Close 動作時執行。 (覆寫 ClientEntity..::..OnClose(TimeSpan)。)
受保護的方法OnClosed (繼承自 ClientEntity。)
受保護的方法OnEndAcceptMessageSession在呼叫 EndAcceptMessageSession 作業時執行。
受保護的方法OnEndClose執行結束關閉動作。 (覆寫 ClientEntity..::..OnEndClose(IAsyncResult)。)
受保護的方法OnEndCreateReceiver執行結束建立接收者動作。
受保護的方法OnEndCreateSender執行結束建立傳送者動作。
受保護的方法OnEndGetMessageSessions執行結束取得訊息動作。
受保護的方法OnEndOpen (繼承自 ClientEntity。)
受保護的方法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)以非同步方式註冊訊息工作階段處理常式處理站。
公用方法Send使用 InternalSender()()()() 傳送訊息。
公用方法SendAsync使用 InternalSender()()()() 非同步傳送訊息。
公用方法SendBatch傳送一組代理訊息 (以進行批次處理)。
公用方法SendBatchAsync非同步傳送一組代理訊息 (以進行批次處理)。
受保護的方法ThrowIfClosed (繼承自 ClientEntity。)
受保護的方法ThrowIfDisposed (繼承自 ClientEntity。)
受保護的方法ThrowIfDisposedOrImmutable (繼承自 ClientEntity。)
受保護的方法ThrowIfDisposedOrNotOpen (繼承自 ClientEntity。)
受保護的方法ThrowIfFaulted (繼承自 ClientEntity。)
公用方法ToString (繼承自 Object。)
上層

This class is mainly used for Service Bus run-time operations, such as sending and receiving messages.

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

// Create the MessagingFactory
     MessagingFactory factory = 
     MessagingFactory.Create(myServiceBusNamespaceUri, SharedSecretTokenProvider.CreateSharedSecretTokenProvider(issuerName, issuerKey));
    
     //********************************************************************************
     //                          Sending messages to a Queue
     //********************************************************************************
    
     // Create queue client
     QueueClient myQueueClient = factory.CreateQueueClient("myQueue");
    
     // Send messages
     List <object>; Issues = new List <object>();
     foreach (var issue in Issues)
     {
        myQueueClient.Send(new BrokeredMessage(issue));
     }
    
     // ... Recieve messages
     for (int count = 0; count < MsgCount; count++)
     {
         var message = myQueueClient.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