ServiceBusReceiver.ReceiveMessagesAsync メソッド

定義

名前空間:

Azure.Messaging.ServiceBus

アセンブリ:

Azure.Messaging.ServiceBus.dll

パッケージ:

Azure.Messaging.ServiceBus v7.17.5

オーバーロード

ReceiveMessagesAsync(CancellationToken)	モードを使用してエンティティから非同期列挙可能としてメッセージを ReceiveMode 受信します。 ReceiveMode の既定値は PeekLock モードです。 IAsyncEnumerable が反復処理されると、エンティティからメッセージが受信されます。 使用可能なメッセージがない場合、このメソッドはメッセージが使用可能になるまでポーリングを続行します。つまり、null を返すことはありません。
ReceiveMessagesAsync(Int32, Nullable<TimeSpan>, CancellationToken)	モードを使用して、エンティティから の ServiceBusReceivedMessage 一覧を ReceiveMode 受け取ります。 ReceiveMode の既定値は PeekLock モードです。 このメソッドは、キューまたはトピックに使用可能なメッセージがあるmaxMessages場合でも、正確なmaxMessagesメッセージを返す保証はありません。

ReceiveMessagesAsync(CancellationToken)

ソース:

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 な インスタンス。

戻り値

IAsyncEnumerable<ServiceBusReceivedMessage>

受信したメッセージ。

ReceiveMessagesAsync(Int32, Nullable<TimeSpan>, CancellationToken)

ソース:

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 な インスタンス。

戻り値

Task<IReadOnlyList<ServiceBusReceivedMessage>>

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