エクスポート (0) 印刷
すべて展開

MessageReceiver クラス

メッセージ コンテナーからメッセージを受信し、受信を確認します。

名前空間:  Microsoft.ServiceBus.Messaging
アセンブリ:  Microsoft.ServiceBus (Microsoft.ServiceBus.dll)

public abstract class MessageReceiver : MessageClientEntity

MessageReceiver 型は、以下のメンバーを公開しています。

  名前説明
パブリック プロパティBatchFlushIntervalバッチ フラッシュの間隔を取得します。
プロテクト プロパティBatchingEnabledバッチが有効かどうかを示す値を取得します。
パブリック プロパティIsClosed (ClientEntity から継承されています。)
パブリック プロパティLastPeekedSequenceNumber最後にピークされたメッセージのシーケンス番号を取得または設定します。
パブリック プロパティModeメッセージ受信モードを取得します。
パブリック プロパティPathMessagingFactory ベース アドレスに相対的なキューまたはトピックのパスを取得します。
パブリック プロパティPrefetchCountメッセージ受信者が同時に要求できるメッセージの数を取得または設定します。
プロテクト プロパティReceiverStartTime
パブリック プロパティRetryPolicy (ClientEntity から継承されています。)
プロテクト プロパティStartOffset
プロテクト プロパティ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 から継承されています。)
パブリック メソッドBeginAbandon(Guid, AsyncCallback, Object)メッセージを破棄し、そのロックを解除する非同期操作を開始します。
パブリック メソッドBeginAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>), 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)メッセージの受信を中断する非同期操作を開始します。
パブリック メソッド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)メッセージのバッチを受信する非同期操作を開始します。
パブリック メソッド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メッセージのバッチに対する受信操作を非同期的に完了します。
パブリック メソッド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メッセージを破棄し、そのロックを解除する非同期操作を終了します。
パブリック メソッドEndCloseメッセージ クライアント エンティティを閉じる非同期操作を終了します。 (MessageClientEntity から継承されています。)
パブリック メソッドEndCompleteメッセージの受信を完了する非同期操作を終了します。
パブリック メソッドEndCompleteBatchバッチ メッセージの受信を完了する非同期操作を終了します。
パブリック メソッドEndDeadLetterメッセージを配信不能キューに移動する非同期操作を終了します。
パブリック メソッドEndDeferメッセージの受信を遅延させる非同期操作を終了します。
パブリック メソッドEndPeekメッセージをピークする非同期操作を終了します。
パブリック メソッドEndPeekBatchメッセージのバッチをピークする非同期操作を終了します。
パブリック メソッドEndReceiveメッセージを受信する非同期操作を終了します。
パブリック メソッドEndReceiveBatchメッセージのバッチを受信する非同期操作を終了します。
パブリック メソッドEquals (Object から継承されています。)
プロテクト メソッドFaultFor internal use only. Do not inherit from this class. (ClientEntity から継承されています。)
プロテクト メソッドFinalize (Object から継承されています。)
パブリック メソッドGetHashCode (Object から継承されています。)
プロテクト メソッド静的メンバーGetLockTokenメッセージにバインドされたロック トークンを取得します。
プロテクト メソッド静的メンバーGetLockTokens指定されたメッセージのコレクションからロック トークンのコレクションを取得します。
パブリック メソッドGetType (Object から継承されています。)
プロテクト メソッドMemberwiseClone (Object から継承されています。)
プロテクト メソッドOnAbandonAbandon 操作を呼び出したときに実行されます。
プロテクト メソッドOnAbort (ClientEntity から継承されています。)
プロテクト メソッドOnBeginAbandonOnAbandon または BeginAbandon 操作を呼び出したときに実行されます。
プロテクト メソッドOnBeginClose (ClientEntity から継承されています。)
プロテクト メソッドOnBeginComplete(TrackingContext, IEnumerable<(Of <<'(ArraySegment<(Of <<'(Byte>)>>)>)>>), Boolean, TimeSpan, AsyncCallback, Object)
プロテクト メソッドOnBeginComplete(TrackingContext, IEnumerable<(Of <<'(Guid>)>>), Boolean, TimeSpan, AsyncCallback, Object)OnComplete または BeginComplete 操作を呼び出したときに実行されます。
プロテクト メソッドOnBeginDeadLetterOnDeadLetter または BeginDeadLetter 操作を呼び出したときに実行されます。
プロテクト メソッドOnBeginDeferOnDefer または BeginDefer 操作を呼び出したときに実行されます。
プロテクト メソッドOnBeginOpen (ClientEntity から継承されています。)
プロテクト メソッドOnBeginPeekBeginPeek 操作を呼び出したときに実行されます。
プロテクト メソッドOnBeginRenewMessageLocksロック メッセージで OnBegin 操作が呼び出されるときに実行します。
プロテクト メソッドOnBeginTryReceive(TrackingContext, IEnumerable<(Of <<'(Int64>)>>), TimeSpan, AsyncCallback, Object)OnTryReceive または BeginTryReceive 操作の呼び出しと同時に実行されます。
プロテクト メソッドOnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)OnTryReceive または BeginTryReceive 操作の呼び出しと同時に実行されます。
プロテクト メソッドOnBeginTryReceive2OnTryReceive または BeginTryReceive 操作の呼び出しと同時に実行されます。
プロテクト メソッドOnBeginTryReceiveEventData
プロテクト メソッドOnClose (ClientEntity から継承されています。)
プロテクト メソッドOnClosed (ClientEntity から継承されています。)
プロテクト メソッドOnCompleteComplete 操作を呼び出したときに実行されます。
プロテクト メソッドOnDeadLetterDeadLetter 操作を呼び出したときに実行されます。
プロテクト メソッドOnDeferDefer 操作を呼び出したときに実行されます。
プロテクト メソッドOnEndAbandon破棄の終了アクションを実行します。
プロテクト メソッドOnEndClose (ClientEntity から継承されています。)
プロテクト メソッドOnEndComplete完了の終了アクションを実行します。
プロテクト メソッドOnEndDeadLetter配信不能キューへの移動を終了するアクションを実行します。
プロテクト メソッドOnEndDefer遅延の終了アクションを実行します。
プロテクト メソッドOnEndOpen (ClientEntity から継承されています。)
プロテクト メソッドOnEndPeekEndPeek 操作を実行します。
プロテクト メソッドOnEndRenewMessageLocksメッセージ ロックの EndRenew アクションを実行します。
プロテクト メソッドOnEndTryReceive受信の試行終了アクションを実行します。
プロテクト メソッドOnEndTryReceive2受信の試行終了アクションを実行します。
プロテクト メソッドOnEndTryReceiveEventData
プロテクト メソッドOnFaulted (ClientEntity から継承されています。)
パブリック メソッドOnMessageイベント駆動型メッセージ ポンプ内のメッセージを処理します。
パブリック メソッドOnMessageAsyncイベント駆動型メッセージ ポンプ内のメッセージを非同期的に処理します。
プロテクト メソッドOnOpen (ClientEntity から継承されています。)
プロテクト メソッドOnOpened (ClientEntity から継承されています。)
プロテクト メソッドOnPeekPeek 操作を呼び出したときに実行されます。
プロテクト メソッドOnRenewMessageLocksロック メッセージの Renew アクションを実行します。
プロテクト メソッドOnTryReceive(TrackingContext, IEnumerable<(Of <<'(Int64>)>>), TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)TryReceive 操作の呼び出しと同時に実行されます。
プロテクト メソッドOnTryReceive(TrackingContext, Int32, TimeSpan, IEnumerable<(Of <<'(BrokeredMessage>)>>)%)TryReceive 操作の呼び出しと同時に実行されます。
パブリック メソッドPeek()()()()受信者またはメッセージ ソースの状態を変更しないで次のメッセージを読み取ります。
パブリック メソッドPeek(Int64)受信者またはメッセージ ソースの状態を変更しないで次のメッセージを読み取ります。
パブリック メソッドPeekAsync()()()()受信者またはメッセージ ソースの状態を変更しないで次のメッセージを非同期的に読み取ります。
パブリック メソッドPeekAsync(Int64)受信者またはメッセージ ソースの状態を変更しないで次のメッセージを非同期的に読み取ります。
パブリック メソッドPeekBatch(Int32)受信者またはメッセージ ソースの状態を変更しないでメッセージの次のバッチを読み取ります。
パブリック メソッドPeekBatch(Int64, Int32)受信者またはメッセージ ソースの状態を変更しないでメッセージの次のバッチを読み取ります。
パブリック メソッドPeekBatchAsync(Int32)受信者またはメッセージ ソースの状態を変更しないでメッセージの次のバッチを非同期的に読み取ります。
パブリック メソッドPeekBatchAsync(Int64, Int32)受信者またはメッセージ ソースの状態を変更しないでメッセージの次のバッチを非同期的に読み取ります。
パブリック メソッドReceive()()()()現在のキューまたはトピックから BrokeredMessage を受信します。
パブリック メソッドReceive(Int64)現在のキューまたはトピックからメッセージを受信します。
パブリック メソッドReceive(TimeSpan)現在のキューまたはトピックから BrokeredMessage を受信します。
パブリック メソッドReceiveAsync()()()()現在のキューまたはトピックからメッセージを非同期的に受信します。
パブリック メソッドReceiveAsync(Int64)現在のキューまたはトピックからメッセージを非同期的に受信します。
パブリック メソッドReceiveAsync(TimeSpan)現在のキューまたはトピックからメッセージを非同期的に受信します。
パブリック メソッドReceiveBatch(IEnumerable<(Of <<'(Int64>)>>))メッセージのバッチを受信します。
パブリック メソッドReceiveBatch(Int32)メッセージのバッチを受信します。
パブリック メソッドReceiveBatch(Int32, TimeSpan)メッセージのバッチを受信します。
パブリック メソッドReceiveBatchAsync(IEnumerable<(Of <<'(Int64>)>>))メッセージのバッチを非同期的に受信します。
パブリック メソッドReceiveBatchAsync(Int32)メッセージのバッチを非同期的に受信します。
パブリック メソッドReceiveBatchAsync(Int32, TimeSpan)メッセージのバッチを非同期的に受信します。
プロテクト メソッドThrowIfClosed (ClientEntity から継承されています。)
プロテクト メソッドThrowIfDisposed (ClientEntity から継承されています。)
プロテクト メソッドThrowIfDisposedOrImmutable (ClientEntity から継承されています。)
プロテクト メソッドThrowIfDisposedOrNotOpen (ClientEntity から継承されています。)
プロテクト メソッドThrowIfFaulted (ClientEntity から継承されています。)
パブリック メソッドToString (Object から継承されています。)
先頭に戻る

Although you can use the QueueClient class to send and receive messages without creating a MessageReceiver object, you can also use MessageSender and MessageReceiver to create a sender and receiver on an entity. However, note that you can only use a MessageReceiver to receive messages from a queue or subscription; you cannot receive messages or listen for messages from a topic. Similarly, you can only use a MessageSender to send messages to a queue or topic; you cannot send messages to a subscription. Note that the default message receive mode is PeekLock, which ensures reliable message receiving.

When you create a MessageReceiver for subscriptions, the entityPath parameter is of the form topicPath/subscriptions/subscriptionName.

The following example receives a message from the queue created in the MessageSender example:

Uri serviceUri = ServiceBusEnvironment.CreateServiceUri("sb", ServiceNamespace, string.Empty); 

MessagingFactory factory = MessagingFactory.Create(serviceUri, credentials); 

MessageReceiver myMessageReceiver = factory.CreateMessageReceiver(queueName);

BrokeredMessage message;
while ((message = myMessageReceiver.Receive(new TimeSpan(hours: 0, minutes: 1, seconds: 5))) != null)
{
    Console.WriteLine(
    string.Format(
    "Message received: Id = {0}, Body = {1}", message.MessageId, message.GetBody<string>()));
    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.

コミュニティの追加

追加
表示:
© 2014 Microsoft