EventHubBufferedProducerClient.EnqueueEventAsync Método

Definição

Namespace:

Azure.Messaging.EventHubs.Producer

Assembly:

Azure.Messaging.EventHubs.dll

Pacote:

Azure.Messaging.EventHubs v5.10.0

Sobrecargas

EnqueueEventAsync(EventData, CancellationToken)

Enfileira um EventData no buffer a ser publicado no Hub de Eventos. Se não houver capacidade no buffer quando esse método for invocado, ele aguardará o espaço ficar disponível e garantirá que o eventData tenha sido enfileirado. Quando essa chamada retorna, o eventData foi aceito no buffer, mas pode não ter sido publicado ainda. A publicação ocorrerá em um ponto não determinístico no futuro à medida que o buffer for processado.

EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken)

Enfileira um EventData no buffer a ser publicado no Hub de Eventos. Se não houver capacidade no buffer quando esse método for invocado, ele aguardará o espaço ficar disponível e garantirá que o eventData tenha sido enfileirado. Quando essa chamada retorna, o eventData foi aceito no buffer, mas pode não ter sido publicado ainda. A publicação ocorrerá em um ponto não determinístico no futuro à medida que o buffer for processado.

EnqueueEventAsync(EventData, CancellationToken)

Enfileira um EventData no buffer a ser publicado no Hub de Eventos. Se não houver capacidade no buffer quando esse método for invocado, ele aguardará o espaço ficar disponível e garantirá que o eventData tenha sido enfileirado.

Quando essa chamada retorna, o eventData foi aceito no buffer, mas pode não ter sido publicado ainda. A publicação ocorrerá em um ponto não determinístico no futuro à medida que o buffer for processado.

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

O evento a ser enfileirado no buffer e, posteriormente, publicado.

cancellationToken

CancellationToken

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

Retornos

Task<Int32>

O número total de eventos que estão atualmente armazenados em buffer e aguardando para serem publicados, em todas as partições.

Exceções

InvalidOperationException

Ocorre quando nenhum SendEventBatchFailedAsync manipulador está registrado no momento.

Comentários

Após a primeira tentativa de enfileirar um evento, os SendEventBatchSucceededAsync manipuladores e SendEventBatchFailedAsync não poderão mais ser alterados.

EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken)

Enfileira um EventData no buffer a ser publicado no Hub de Eventos. Se não houver capacidade no buffer quando esse método for invocado, ele aguardará o espaço ficar disponível e garantirá que o eventData tenha sido enfileirado.

Quando essa chamada retorna, o eventData foi aceito no buffer, mas pode não ter sido publicado ainda. A publicação ocorrerá em um ponto não determinístico no futuro à medida que o buffer for processado.

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

O evento a ser enfileirado no buffer e, posteriormente, publicado.

options

EnqueueEventOptions

O conjunto de opções a serem aplicadas ao publicar esse evento.

cancellationToken

CancellationToken

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

Retornos

Task<Int32>

O número total de eventos que estão atualmente armazenados em buffer e aguardando para serem publicados, em todas as partições.

Exceções

InvalidOperationException

Ocorre quando um identificador de partição inválido foi especificado no options.

Comentários

Após a primeira tentativa de enfileirar um evento, os SendEventBatchSucceededAsync manipuladores e SendEventBatchFailedAsync não poderão mais ser alterados.