PartitionReceiver.ReceiveBatchAsync Método
Definición
Importante
Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.
Sobrecargas
| ReceiveBatchAsync(Int32, CancellationToken) |
Recibe un lote de la partición del centro de EventData eventos con la que está asociado este cliente. |
| ReceiveBatchAsync(Int32, TimeSpan, CancellationToken) |
Recibe un lote de la partición del centro de EventData eventos con la que está asociado este cliente. |
ReceiveBatchAsync(Int32, CancellationToken)
- Source:
- PartitionReceiver.cs
- Source:
- PartitionReceiver.cs
Recibe un lote de la partición del centro de EventData eventos con la que está asociado este cliente.
public virtual System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.EventData>> ReceiveBatchAsync (int maximumEventCount, System.Threading.CancellationToken cancellationToken = default);abstract member ReceiveBatchAsync : int * System.Threading.CancellationToken -> System.Threading.Tasks.Task<seq<Azure.Messaging.EventHubs.EventData>>
override this.ReceiveBatchAsync : int * System.Threading.CancellationToken -> System.Threading.Tasks.Task<seq<Azure.Messaging.EventHubs.EventData>>Public Overridable Function ReceiveBatchAsync (maximumEventCount As Integer, Optional cancellationToken As CancellationToken = Nothing) As Task(Of IEnumerable(Of EventData))Parámetros
- maximumEventCount
- Int32
Número máximo de mensajes que se van a recibir en este lote.
- cancellationToken
- CancellationToken
Una instancia opcional CancellationToken para indicar la solicitud para cancelar la operación.
Devoluciones
Lote de la partición del centro de EventData eventos con la que está asociado este cliente. Si no hay ningún evento, se devuelve un enumerador vacío.
Excepciones
Se produce cuando la solicitud maximumEventCount es inferior a 1.
Se produce cuando no PartitionReceiver se puede leer desde la partición solicitada del centro de eventos debido a que otro lector ha declarado la propiedad exclusiva. En este caso, EventHubsException.FailureReason se establecerá ConsumerDisconnecteden .
Comentarios
Cuando los eventos estén disponibles en la cola de captura previa, se usarán para formar el lote lo antes posible sin esperar a que se produzcan eventos adicionales del servicio Event Hubs para probar y cumplir con el solicitado maximumEventCount. Cuando no haya ningún evento disponible en la captura previa, el receptor esperará hasta la duración especificada por en la TryTimeout directiva de reintento activo para que los eventos se lean desde el servicio. Una vez que haya eventos disponibles, se usarán para formar el lote inmediatamente.
Se aplica a
ReceiveBatchAsync(Int32, TimeSpan, CancellationToken)
- Source:
- PartitionReceiver.cs
- Source:
- PartitionReceiver.cs
Recibe un lote de la partición del centro de EventData eventos con la que está asociado este cliente.
public virtual System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.EventData>> ReceiveBatchAsync (int maximumEventCount, TimeSpan maximumWaitTime, System.Threading.CancellationToken cancellationToken = default);abstract member ReceiveBatchAsync : int * TimeSpan * System.Threading.CancellationToken -> System.Threading.Tasks.Task<seq<Azure.Messaging.EventHubs.EventData>>
override this.ReceiveBatchAsync : int * TimeSpan * System.Threading.CancellationToken -> System.Threading.Tasks.Task<seq<Azure.Messaging.EventHubs.EventData>>Public Overridable Function ReceiveBatchAsync (maximumEventCount As Integer, maximumWaitTime As TimeSpan, Optional cancellationToken As CancellationToken = Nothing) As Task(Of IEnumerable(Of EventData))Parámetros
- maximumEventCount
- Int32
Número máximo de mensajes que se van a recibir en este lote.
- maximumWaitTime
- TimeSpan
Cantidad máxima de tiempo para esperar a que los eventos estén disponibles, si no se puede leer ningún evento de la cola de captura previa.
- cancellationToken
- CancellationToken
Una instancia opcional CancellationToken para indicar la solicitud para cancelar la operación.
Devoluciones
Lote de la partición del centro de EventData eventos con la que está asociado este cliente. Si no hay ningún evento, se devuelve un enumerador vacío.
Excepciones
Se produce cuando la solicitud maximumEventCount es inferior a 1.
Se produce cuando no PartitionReceiver se puede leer desde la partición solicitada del centro de eventos debido a que otro lector ha declarado la propiedad exclusiva. En este caso, EventHubsException.FailureReason se establecerá ConsumerDisconnecteden .
Comentarios
Cuando los eventos estén disponibles en la cola de captura previa, se usarán para formar el lote lo antes posible sin esperar a que se produzcan eventos adicionales del servicio Event Hubs para probar y cumplir con el solicitado maximumEventCount. Cuando no haya ningún evento disponible en la captura previa, el receptor esperará a que maximumWaitTime los eventos se lean desde el servicio. Una vez que haya eventos disponibles, se usarán para formar el lote inmediatamente.
Se aplica a
Azure SDK for .NET