Compartir a través de

EventHubBufferedProducerClient.EnqueueEventAsync Método

  • Referencia

Definición

Espacio de nombres:
Azure.Messaging.EventHubs.Producer
Ensamblado:
Azure.Messaging.EventHubs.dll
Paquete:
Azure.Messaging.EventHubs v5.10.0

Sobrecargas

EnqueueEventAsync(EventData, CancellationToken)

Pone en cola un en EventData el búfer que se va a publicar en el centro de eventos. Si no hay capacidad en el búfer cuando se invoca este método, esperará a que haya espacio disponible y se asegurará de que eventData se ha puesto en cola.

Cuando se devuelve esta llamada, se eventData ha aceptado en el búfer, pero es posible que aún no se haya publicado. La publicación tendrá lugar en un punto no determinista en el futuro a medida que se procesa el búfer.
EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken)

Pone en cola un en EventData el búfer que se va a publicar en el centro de eventos. Si no hay capacidad en el búfer cuando se invoca este método, esperará a que haya espacio disponible y se asegurará de que eventData se ha puesto en cola.

Cuando se devuelve esta llamada, se eventData ha aceptado en el búfer, pero es posible que aún no se haya publicado. La publicación tendrá lugar en un punto no determinista en el futuro a medida que se procesa el búfer.

EnqueueEventAsync(EventData, CancellationToken)

Pone en cola un en EventData el búfer que se va a publicar en el centro de eventos. Si no hay capacidad en el búfer cuando se invoca este método, esperará a que haya espacio disponible y se asegurará de que eventData se ha puesto en cola.

Cuando se devuelve esta llamada, se eventData ha aceptado en el búfer, pero es posible que aún no se haya publicado. La publicación tendrá lugar en un punto no determinista en el futuro a medida que se procesa el búfer.

public virtual System.Threading.Tasks.Task<int> EnqueueEventAsync (Azure.Messaging.EventHubs.EventData eventData, System.Threading.CancellationToken cancellationToken = default);
abstract member EnqueueEventAsync : Azure.Messaging.EventHubs.EventData * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
override this.EnqueueEventAsync : Azure.Messaging.EventHubs.EventData * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
Public Overridable Function EnqueueEventAsync (eventData As EventData, Optional cancellationToken As CancellationToken = Nothing) As Task(Of Integer)

Parámetros

eventData
EventData

Evento que se va a poner en cola en el búfer y, más adelante, publicado.

cancellationToken
CancellationToken

Una instancia opcional CancellationToken para indicar la solicitud para cancelar la operación.

Devoluciones

Task<Int32>

Número total de eventos almacenados en búfer y en espera de publicación, en todas las particiones.

Excepciones

InvalidOperationException

Se produce cuando no hay ningún SendEventBatchFailedAsync controlador registrado actualmente.

Comentarios

Tras el primer intento de poner en cola un evento, los SendEventBatchSucceededAsync controladores y SendEventBatchFailedAsync ya no se pueden cambiar.

Se aplica a

EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken)

Pone en cola un en EventData el búfer que se va a publicar en el centro de eventos. Si no hay capacidad en el búfer cuando se invoca este método, esperará a que haya espacio disponible y se asegurará de que eventData se ha puesto en cola.

Cuando se devuelve esta llamada, se eventData ha aceptado en el búfer, pero es posible que aún no se haya publicado. La publicación tendrá lugar en un punto no determinista en el futuro a medida que se procesa el búfer.

public virtual System.Threading.Tasks.Task<int> EnqueueEventAsync (Azure.Messaging.EventHubs.EventData eventData, Azure.Messaging.EventHubs.Producer.EnqueueEventOptions options, System.Threading.CancellationToken cancellationToken = default);
abstract member EnqueueEventAsync : Azure.Messaging.EventHubs.EventData * Azure.Messaging.EventHubs.Producer.EnqueueEventOptions * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
override this.EnqueueEventAsync : Azure.Messaging.EventHubs.EventData * Azure.Messaging.EventHubs.Producer.EnqueueEventOptions * System.Threading.CancellationToken -> System.Threading.Tasks.Task<int>
Public Overridable Function EnqueueEventAsync (eventData As EventData, options As EnqueueEventOptions, Optional cancellationToken As CancellationToken = Nothing) As Task(Of Integer)

Parámetros

eventData
EventData

Evento que se va a poner en cola en el búfer y, más adelante, publicado.

options
EnqueueEventOptions

Conjunto de opciones que se aplicarán al publicar este evento.

cancellationToken
CancellationToken

Una instancia opcional CancellationToken para indicar la solicitud para cancelar la operación.

Devoluciones

Task<Int32>

Número total de eventos almacenados en búfer y en espera de publicación, en todas las particiones.

Excepciones

InvalidOperationException

Se produce cuando se ha especificado un identificador de partición no válido en .options

Comentarios

Tras el primer intento de poner en cola un evento, los SendEventBatchSucceededAsync controladores y SendEventBatchFailedAsync ya no se pueden cambiar.

Se aplica a