ServiceBusReceiver.ReceiveMessagesAsync Método

  • Referência

Definição

Namespace:
Azure.Messaging.ServiceBus
Assembly:
Azure.Messaging.ServiceBus.dll
Pacote:
Azure.Messaging.ServiceBus v7.17.5
Pacote:
Azure.Messaging.ServiceBus v7.18.0-beta.1

Sobrecargas

ReceiveMessagesAsync(CancellationToken)

Recebe mensagens como um enumerável assíncrono da entidade usando ReceiveMode o modo . ReceiveMode usa como padrão o modo PeekLock. As mensagens serão recebidas da entidade à medida que iAsyncEnumerable for iterado. Se nenhuma mensagem estiver disponível, esse método continuará sondando até que as mensagens estejam disponíveis, ou seja, ele nunca retornará nulo.
ReceiveMessagesAsync(Int32, Nullable<TimeSpan>, CancellationToken)

Recebe uma lista de ServiceBusReceivedMessage da entidade usando ReceiveMode o modo . ReceiveMode usa como padrão o modo PeekLock. Esse método não garante o retorno de mensagens exatas maxMessages , mesmo que haja maxMessages mensagens disponíveis na fila ou no tópico.

ReceiveMessagesAsync(CancellationToken)

Origem:
ServiceBusReceiver.cs
Origem:
ServiceBusReceiver.cs

Recebe mensagens como um enumerável assíncrono da entidade usando ReceiveMode o modo . ReceiveMode usa como padrão o modo PeekLock. As mensagens serão recebidas da entidade à medida que iAsyncEnumerable for iterado. Se nenhuma mensagem estiver disponível, esse método continuará sondando até que as mensagens estejam disponíveis, ou seja, ele nunca retornará nulo.

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)

Parâmetros

cancellationToken
CancellationToken

Uma instância opcional CancellationToken para sinalizar a solicitação para cancelar a operação.

Retornos

IAsyncEnumerable<ServiceBusReceivedMessage>

A mensagem recebida.

Aplica-se a

ReceiveMessagesAsync(Int32, Nullable<TimeSpan>, CancellationToken)

Origem:
ServiceBusReceiver.cs
Origem:
ServiceBusReceiver.cs

Recebe uma lista de ServiceBusReceivedMessage da entidade usando ReceiveMode o modo . ReceiveMode usa como padrão o modo PeekLock. Esse método não garante o retorno de mensagens exatas maxMessages , mesmo que haja maxMessages mensagens disponíveis na fila ou no tópico.

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))

Parâmetros

maxMessages
Int32

O número máximo de mensagens que serão recebidas.

maxWaitTime
Nullable<TimeSpan>

Um opcional TimeSpan que especifica o tempo máximo para aguardar a primeira mensagem antes de retornar uma lista vazia se nenhuma mensagem estiver disponível. Se não for especificado, o TryTimeout será usado.

cancellationToken
CancellationToken

Uma instância opcional CancellationToken para sinalizar a solicitação para cancelar a operação.

Retornos

Task<IReadOnlyList<ServiceBusReceivedMessage>>

Lista de mensagens recebidas. Retornará uma lista vazia se nenhuma mensagem for encontrada.

Aplica-se a