セールス: 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()()()()1 回のトランザクションで処理する関連メッセージのグループ化を許可するメッセージ セッションを受け付けます。
パブリック メソッドAcceptMessageSession(String)特定のセッション ID を使用して、1 回のトランザクションで処理する関連メッセージのグループ化を許可するメッセージ セッションを受け付けます。
パブリック メソッドAcceptMessageSession(TimeSpan)指定されたサーバー待機時間を使用して、1 回のトランザクションで処理する関連メッセージのグループ化を許可するメッセージ セッションを受け付けます。
パブリック メソッドAcceptMessageSession(String, TimeSpan)特定のセッション ID および待機時間を使用して、1 回のトランザクションで処理する関連メッセージのグループ化を許可するメッセージ セッションを受け付けます。
パブリック メソッドAcceptMessageSessionAsync()()()()1 回のトランザクションで処理する関連メッセージのグループ化を許可するメッセージ セッションを非同期的に受け付けます。
パブリック メソッドAcceptMessageSessionAsync(String)特定のセッション ID を使用して、1 回のトランザクションで処理する関連メッセージのグループ化を許可するメッセージ セッションを非同期的に受け付けます。
パブリック メソッドAcceptMessageSessionAsync(TimeSpan)指定されたサーバー待機時間を使用して、1 回のトランザクションで処理する関連メッセージのグループ化を許可するメッセージ セッションを非同期的に受け付けます。
パブリック メソッドAcceptMessageSessionAsync(String, TimeSpan)特定のセッション ID および待機時間を使用して、1 回のトランザクションで処理する関連メッセージのグループ化を許可するメッセージ セッションを非同期的に受け付けます。
パブリック メソッド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複数のメッセージを 1 回のトランザクションで処理するための、関連メッセージのグループ化を許可するメッセージ セッションを受け入れる非同期操作を完了します。
パブリック メソッド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 から継承されています。)
プロテクト メソッドOnAbortAbort イベントを呼び出したときに実行されます。 (ClientEntity..::..OnAbort()()()() をオーバーライドします。)
プロテクト メソッドOnBeginAcceptMessageSessionBeginAcceptMessageSession 操作の呼び出しと同時に実行されます。
プロテクト メソッドOnBeginCloseClose 操作を呼び出したときに実行されます。 (ClientEntity..::..OnBeginClose(TimeSpan, AsyncCallback, Object) をオーバーライドします。)
プロテクト メソッドOnBeginCreateReceiver(ReceiveMode, TimeSpan, AsyncCallback, Object)受信者の作成開始アクションを実行します。
プロテクト メソッドOnBeginCreateReceiver(String, ReceiveMode, TimeSpan, AsyncCallback, Object)受信者の作成開始アクションを実行します。
プロテクト メソッドOnBeginCreateSender送信者の作成開始アクションを実行します。
プロテクト メソッドOnBeginGetMessageSessionsBeginGetMessageSessions アクションを実行します。
プロテクト メソッドOnBeginOpen (ClientEntity から継承されています。)
プロテクト メソッドOnCloseClose アクションを呼び出したときに実行されます。 (ClientEntity..::..OnClose(TimeSpan) をオーバーライドします。)
プロテクト メソッドOnClosed (ClientEntity から継承されています。)
プロテクト メソッドOnEndAcceptMessageSessionEndAcceptMessageSession 操作の呼び出しと同時に実行されます。
プロテクト メソッド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)メッセージ セッションのハンドラー ファクトリを非同期的に登録します。
パブリック メソッドSendInternalSender()()()() を使用してメッセージを送信します。
パブリック メソッドSendAsyncInternalSender()()()() を使用してメッセージを非同期的に送信します。
パブリック メソッド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