エクスポート (0) 印刷
すべて展開
このトピックはまだ評価されていません - このトピックを評価する

MessageReceiver クラス

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

名前空間:  Microsoft.ServiceBus.Messaging
アセンブリ:  Microsoft.ServiceBus (Microsoft.ServiceBus.dll)
'宣言
Public MustInherit Class MessageReceiver _
	Inherits MessageClientEntity
'使用
Dim instance As MessageReceiver

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

  名前説明
パブリック プロパティBatchFlushIntervalバッチ フラッシュの間隔を取得します。
プロテクト プロパティBatchingEnabledバッチが有効かどうかを示す値を取得します。
パブリック プロパティIsClosedメッセージ クライアント エンティティが閉じられているかどうかを示す値を取得または設定します。 (MessageClientEntity から継承されています。)
パブリック プロパティLastPeekedSequenceNumber最後にピークされたメッセージのシーケンス番号を取得または設定します。
パブリック プロパティModeメッセージ受信モードを取得します。
パブリック プロパティPathMessagingFactory ベース アドレスに相対的なキューまたはトピックのパスを取得します。
パブリック プロパティPrefetchCountメッセージ受信者が同時に要求できるメッセージの数を取得または設定します。
パブリック プロパティRetryPolicy要求を再試行するかどうかを決定するこのインスタンスに関連付けられている再試行ポリシーを取得または設定します。 (MessageClientEntity から継承されています。)
プロテクト プロパティThisLockMessageClientEntity インスタンスをロックするために使用されたオブジェクトを取得します。 (MessageClientEntity から継承されています。)
先頭に戻る
  名前説明
パブリック メソッドAbandon(Guid)メッセージを破棄し、メッセージ ロックの所有権を解除します。
パブリック メソッドAbandon(Guid, IDictionary<(Of <<'(String, Object>)>>))メッセージを破棄し、メッセージ ロックの所有権を解除します。
パブリック メソッドAbandonAsync(Guid)非同期的にメッセージを破棄し、メッセージ ロックの所有権を解除します。
パブリック メソッドAbandonAsync(Guid, IDictionary<(Of <<'(String, Object>)>>))非同期的にメッセージを破棄し、メッセージ ロックの所有権を解除します。
パブリック メソッドAbortメッセージ クライアント エンティティを破棄し、その状態を終了状態に設定します。 (MessageClientEntity から継承されています。)
パブリック メソッド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)メッセージのバッチを受信する非同期操作を開始します。
パブリック メソッドCloseメッセージ クライアント エンティティを閉じ、その状態を終了状態に設定します。 (MessageClientEntity から継承されています。)
パブリック メソッドCloseAsync非同期的にメッセージ クライアント エンティティを閉じ、その状態を終了状態に設定します。 (MessageClientEntity から継承されています。)
パブリック メソッド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 から継承されています。)
プロテクト メソッドFaultメッセージ クライアント エンティティをエラー状態に設定します。 (MessageClientEntity から継承されています。)
プロテクト メソッドFinalize (Object から継承されています。)
パブリック メソッドGetHashCode (Object から継承されています。)
プロテクト メソッド静的メンバーGetLockTokenメッセージにバインドされたロック トークンを取得します。
プロテクト メソッド静的メンバーGetLockTokens指定されたメッセージのコレクションからロック トークンのコレクションを取得します。
パブリック メソッドGetType (Object から継承されています。)
プロテクト メソッドMemberwiseClone (Object から継承されています。)
プロテクト メソッドOnAbandonAbandon 操作を呼び出したときに実行されます。
プロテクト メソッドOnAbortAbort 操作を呼び出したときに実行されます。 (MessageClientEntity から継承されています。)
プロテクト メソッドOnBeginAbandonOnAbandon または BeginAbandon 操作を呼び出したときに実行されます。
プロテクト メソッドOnBeginCloseBeginClose 操作を呼び出したときに実行されます。 (MessageClientEntity から継承されています。)
プロテクト メソッドOnBeginCompleteOnComplete または BeginComplete 操作を呼び出したときに実行されます。
プロテクト メソッドOnBeginDeadLetterOnDeadLetter または BeginDeadLetter 操作を呼び出したときに実行されます。
プロテクト メソッドOnBeginDeferOnDefer または BeginDefer 操作を呼び出したときに実行されます。
プロテクト メソッドOnBeginOpenメッセージ クライアント エンティティを開くことを開始する操作を呼び出したときに実行されます。 (MessageClientEntity から継承されています。)
プロテクト メソッドOnBeginPeekBeginPeek 操作を呼び出したときに実行されます。
プロテクト メソッドOnBeginRenewMessageLocksロック メッセージで OnBegin 操作が呼び出されるときに実行します。
プロテクト メソッドOnBeginTryReceive(TrackingContext, IEnumerable<(Of <<'(Int64>)>>), TimeSpan, AsyncCallback, Object)OnTryReceive または BeginTryReceive 操作の呼び出しと同時に実行されます。
プロテクト メソッドOnBeginTryReceive(TrackingContext, Int32, TimeSpan, AsyncCallback, Object)OnTryReceive または BeginTryReceive 操作の呼び出しと同時に実行されます。
プロテクト メソッドOnBeginTryReceive2OnTryReceive または BeginTryReceive 操作の呼び出しと同時に実行されます。
プロテクト メソッドOnCloseClose 操作を呼び出したときに実行されます。 (MessageClientEntity から継承されています。)
プロテクト メソッドOnClosedメッセージ クライアント エンティティが終了状態に移行したときに発生します。 (MessageClientEntity から継承されています。)
プロテクト メソッドOnCompleteComplete 操作を呼び出したときに実行されます。
プロテクト メソッドOnDeadLetterDeadLetter 操作を呼び出したときに実行されます。
プロテクト メソッドOnDeferDefer 操作を呼び出したときに実行されます。
プロテクト メソッドOnEndAbandon破棄の終了アクションを実行します。
プロテクト メソッドOnEndCloseEndClose 操作を呼び出したときに実行されます。 (MessageClientEntity から継承されています。)
プロテクト メソッドOnEndComplete完了の終了アクションを実行します。
プロテクト メソッドOnEndDeadLetter配信不能キューへの移動を終了するアクションを実行します。
プロテクト メソッドOnEndDefer遅延の終了アクションを実行します。
プロテクト メソッドOnEndOpenメッセージ クライアント エンティティを開くことを終了する操作を呼び出したときに実行されます。 (MessageClientEntity から継承されています。)
プロテクト メソッドOnEndPeekEndPeek 操作を実行します。
プロテクト メソッドOnEndRenewMessageLocksメッセージ ロックの EndRenew アクションを実行します。
プロテクト メソッドOnEndTryReceive受信の試行終了アクションを実行します。
プロテクト メソッドOnEndTryReceive2受信の試行終了アクションを実行します。
プロテクト メソッドOnFaultedFault 操作を呼び出したときに実行されます。 (MessageClientEntity から継承されています。)
パブリック メソッドOnMessageイベント駆動型メッセージ ポンプ内のメッセージを処理します。
パブリック メソッドOnMessageAsyncイベント駆動型メッセージ ポンプ内のメッセージを非同期的に処理します。
プロテクト メソッドOnOpenメッセージ クライアント エンティティを開く操作を呼び出したときに実行されます。 (MessageClientEntity から継承されています。)
プロテクト メソッドOnOpenedメッセージ クライアント エンティティが開かれたときに実行されます。 (MessageClientEntity から継承されています。)
プロテクト メソッドOnPeekPeek 操作を呼び出したときに実行されます。
プロテクト メソッドOnRenewMessageLocksロック メッセージの Renew アクションを実行します。
プロテクト メソッドOnRuntimeDescriptionChangedランタイムの説明が変更された時にイベントを発行します。 (MessageClientEntity から継承されています。)
プロテクト メソッド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メッセージ クライアント エンティティが閉じられた場合に例外をスローします。 (MessageClientEntity から継承されています。)
プロテクト メソッドThrowIfDisposedメッセージ クライアント エンティティが破棄された場合に例外をスローします。 (MessageClientEntity から継承されています。)
プロテクト メソッドThrowIfDisposedOrImmutableクライアントが破棄されたか不変の場合に例外をスローします。 (MessageClientEntity から継承されています。)
プロテクト メソッドThrowIfDisposedOrNotOpenクライアントが破棄されたか開いていない場合に例外をスローします。 (MessageClientEntity から継承されています。)
プロテクト メソッドThrowIfFaultedクライアントにエラーが発生した場合に例外をスローします。 (MessageClientEntity から継承されています。)
パブリック メソッド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.

この情報は役に立ちましたか。
(残り 1500 文字)
フィードバックをいただき、ありがとうございました

コミュニティの追加

追加
表示:
© 2014 Microsoft. All rights reserved.