次の方法で共有


ServiceBusReceiver.ReceiveMessagesAsync メソッド

定義

オーバーロード

ReceiveMessagesAsync(CancellationToken)

モードを使用してエンティティから非同期列挙可能としてメッセージを ReceiveMode 受信します。 ReceiveMode の既定値は PeekLock モードです。 IAsyncEnumerable が反復処理されると、エンティティからメッセージが受信されます。 使用可能なメッセージがない場合、このメソッドはメッセージが使用可能になるまでポーリングを続行します。つまり、null を返すことはありません。

ReceiveMessagesAsync(Int32, Nullable<TimeSpan>, CancellationToken)

モードを使用して、エンティティから の ServiceBusReceivedMessage 一覧を ReceiveMode 受け取ります。 ReceiveMode の既定値は PeekLock モードです。 このメソッドは、キューまたはトピックに使用可能なメッセージがあるmaxMessages場合でも、正確なmaxMessagesメッセージを返す保証はありません。

ReceiveMessagesAsync(CancellationToken)

ソース:
ServiceBusReceiver.cs
ソース:
ServiceBusReceiver.cs

モードを使用してエンティティから非同期列挙可能としてメッセージを ReceiveMode 受信します。 ReceiveMode の既定値は PeekLock モードです。 IAsyncEnumerable が反復処理されると、エンティティからメッセージが受信されます。 使用可能なメッセージがない場合、このメソッドはメッセージが使用可能になるまでポーリングを続行します。つまり、null を返すことはありません。

public virtual System.Collections.Generic.IAsyncEnumerable<Azure.Messaging.ServiceBus.ServiceBusReceivedMessage> ReceiveMessagesAsync (System.Threading.CancellationToken cancellationToken = default);
abstract member ReceiveMessagesAsync : System.Threading.CancellationToken -> System.Collections.Generic.IAsyncEnumerable<Azure.Messaging.ServiceBus.ServiceBusReceivedMessage>
override this.ReceiveMessagesAsync : System.Threading.CancellationToken -> System.Collections.Generic.IAsyncEnumerable<Azure.Messaging.ServiceBus.ServiceBusReceivedMessage>
Public Overridable Function ReceiveMessagesAsync (Optional cancellationToken As CancellationToken = Nothing) As IAsyncEnumerable(Of ServiceBusReceivedMessage)

パラメーター

cancellationToken
CancellationToken

操作を取り消す要求を通知する省略可能 CancellationToken な インスタンス。

戻り値

受信したメッセージ。

適用対象

ReceiveMessagesAsync(Int32, Nullable<TimeSpan>, CancellationToken)

ソース:
ServiceBusReceiver.cs
ソース:
ServiceBusReceiver.cs

モードを使用して、エンティティから の ServiceBusReceivedMessage 一覧を ReceiveMode 受け取ります。 ReceiveMode の既定値は PeekLock モードです。 このメソッドは、キューまたはトピックに使用可能なメッセージがあるmaxMessages場合でも、正確なmaxMessagesメッセージを返す保証はありません。

public virtual System.Threading.Tasks.Task<System.Collections.Generic.IReadOnlyList<Azure.Messaging.ServiceBus.ServiceBusReceivedMessage>> ReceiveMessagesAsync (int maxMessages, TimeSpan? maxWaitTime = default, System.Threading.CancellationToken cancellationToken = default);
abstract member ReceiveMessagesAsync : int * Nullable<TimeSpan> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<System.Collections.Generic.IReadOnlyList<Azure.Messaging.ServiceBus.ServiceBusReceivedMessage>>
override this.ReceiveMessagesAsync : int * Nullable<TimeSpan> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<System.Collections.Generic.IReadOnlyList<Azure.Messaging.ServiceBus.ServiceBusReceivedMessage>>
Public Overridable Function ReceiveMessagesAsync (maxMessages As Integer, Optional maxWaitTime As Nullable(Of TimeSpan) = Nothing, Optional cancellationToken As CancellationToken = Nothing) As Task(Of IReadOnlyList(Of ServiceBusReceivedMessage))

パラメーター

maxMessages
Int32

受信するメッセージの最大数。

maxWaitTime
Nullable<TimeSpan>

使用可能なメッセージがない場合に空のリストを返す前に、最初のメッセージを待機する最大時間を指定する省略可能 TimeSpan です。 指定しない場合は、 が TryTimeout 使用されます。

cancellationToken
CancellationToken

操作を取り消す要求を通知する省略可能 CancellationToken な インスタンス。

戻り値

受信したメッセージの一覧。 メッセージが見つからない場合は、空のリストを返します。

適用対象