Partager via

EventHubBufferedProducerClient.EnqueueEventAsync Méthode

  • Référence

Définition

Espace de noms:
Azure.Messaging.EventHubs.Producer
Assembly:
Azure.Messaging.EventHubs.dll
Paquet:
Azure.Messaging.EventHubs v5.10.0

Surcharges

EnqueueEventAsync(EventData, CancellationToken)

Met en file d’attente un EventData dans la mémoire tampon à publier dans Event Hub. S’il n’y a pas de capacité dans la mémoire tampon lorsque cette méthode est appelée, elle attend que l’espace soit disponible et s’assure que le eventData a été mis en file d’attente.

Lorsque cet appel est retourné, le eventData a été accepté dans la mémoire tampon, mais il n’a peut-être pas encore été publié. La publication aura lieu à un point non déterministe à l’avenir à mesure que la mémoire tampon sera traitée.
EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken)

Met en file d’attente un EventData dans la mémoire tampon à publier dans Event Hub. S’il n’y a pas de capacité dans la mémoire tampon lorsque cette méthode est appelée, elle attend que l’espace soit disponible et s’assure que le eventData a été mis en file d’attente.

Lorsque cet appel est retourné, le eventData a été accepté dans la mémoire tampon, mais il n’a peut-être pas encore été publié. La publication aura lieu à un point non déterministe à l’avenir à mesure que la mémoire tampon sera traitée.

EnqueueEventAsync(EventData, CancellationToken)

Met en file d’attente un EventData dans la mémoire tampon à publier dans Event Hub. S’il n’y a pas de capacité dans la mémoire tampon lorsque cette méthode est appelée, elle attend que l’espace soit disponible et s’assure que le eventData a été mis en file d’attente.

Lorsque cet appel est retourné, le eventData a été accepté dans la mémoire tampon, mais il n’a peut-être pas encore été publié. La publication aura lieu à un point non déterministe à l’avenir à mesure que la mémoire tampon sera traitée.

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)

Paramètres

eventData
EventData

Événement à mettre en file d’attente dans la mémoire tampon et, plus tard, à publier.

cancellationToken
CancellationToken

Une instance facultative CancellationToken pour signaler la demande d’annulation de l’opération.

Retours

Task<Int32>

Nombre total d’événements actuellement mis en mémoire tampon et en attente de publication, sur toutes les partitions.

Exceptions

InvalidOperationException

Se produit lorsqu’aucun gestionnaire n’est SendEventBatchFailedAsync actuellement inscrit.

Remarques

Lors de la première tentative de mise en file d’attente d’un événement, les SendEventBatchSucceededAsync gestionnaires et SendEventBatchFailedAsync ne peuvent plus être modifiés.

S’applique à

EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken)

Met en file d’attente un EventData dans la mémoire tampon à publier dans Event Hub. S’il n’y a pas de capacité dans la mémoire tampon lorsque cette méthode est appelée, elle attend que l’espace soit disponible et s’assure que le eventData a été mis en file d’attente.

Lorsque cet appel est retourné, le eventData a été accepté dans la mémoire tampon, mais il n’a peut-être pas encore été publié. La publication aura lieu à un point non déterministe à l’avenir à mesure que la mémoire tampon sera traitée.

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)

Paramètres

eventData
EventData

Événement à mettre en file d’attente dans la mémoire tampon et, plus tard, à publier.

options
EnqueueEventOptions

Ensemble d’options à appliquer lors de la publication de cet événement.

cancellationToken
CancellationToken

Une instance facultative CancellationToken pour signaler la demande d’annulation de l’opération.

Retours

Task<Int32>

Nombre total d’événements actuellement mis en mémoire tampon et en attente de publication, sur toutes les partitions.

Exceptions

InvalidOperationException

Se produit lorsqu’un identificateur de partition non valide a été spécifié dans le options.

Remarques

Lors de la première tentative de mise en file d’attente d’un événement, les SendEventBatchSucceededAsync gestionnaires et SendEventBatchFailedAsync ne peuvent plus être modifiés.

S’applique à