你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

EventHubBufferedProducerClient.EnqueueEventAsync 方法

定义

命名空间:

Azure.Messaging.EventHubs.Producer

程序集:

Azure.Messaging.EventHubs.dll

包:

Azure.Messaging.EventHubs v5.10.0

重载

EnqueueEventAsync(EventData, CancellationToken)	将 EventData 排入要发布到事件中心的缓冲区。 如果在调用此方法时缓冲区中没有容量，它将等待可用空间，并确保 eventData 已排队。 当此调用返回时， eventData 缓冲区中已接受 ，但可能尚未发布。 在处理缓冲区时，发布将在将来的不确定点进行。
EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken)	将 EventData 排入要发布到事件中心的缓冲区。 如果在调用此方法时缓冲区中没有容量，它将等待可用空间，并确保 eventData 已排队。 当此调用返回时， eventData 缓冲区中已接受 ，但可能尚未发布。 在处理缓冲区时，发布将在将来的不确定点进行。

EnqueueEventAsync(EventData, CancellationToken)

将 EventData 排入要发布到事件中心的缓冲区。 如果在调用此方法时缓冲区中没有容量，它将等待可用空间，并确保 eventData 已排队。

当此调用返回时， eventData 缓冲区中已接受 ，但可能尚未发布。 在处理缓冲区时，发布将在将来的不确定点进行。

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)

参数

eventData

EventData

要排队到缓冲区并在以后发布的事件。

cancellationToken

CancellationToken

一个可选 CancellationToken 实例，用于发出取消操作的请求信号。

返回

Task<Int32>

所有分区中当前缓冲并等待发布的事件总数。

例外

InvalidOperationException

当前未注册处理程序 SendEventBatchFailedAsync 时发生。

注解

首次尝试将事件排入队列时， SendEventBatchSucceededAsync 无法再更改 和 SendEventBatchFailedAsync 处理程序。

EnqueueEventAsync(EventData, EnqueueEventOptions, CancellationToken)

将 EventData 排入要发布到事件中心的缓冲区。 如果在调用此方法时缓冲区中没有容量，它将等待可用空间，并确保 eventData 已排队。

当此调用返回时， eventData 缓冲区中已接受 ，但可能尚未发布。 在处理缓冲区时，发布将在将来的不确定点进行。

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)

参数

eventData

EventData

要排队到缓冲区并在以后发布的事件。

options

EnqueueEventOptions

发布此事件时要应用的选项集。

cancellationToken

CancellationToken

一个可选 CancellationToken 实例，用于发出取消操作的请求信号。

返回

Task<Int32>

所有分区中当前缓冲并等待发布的事件总数。

例外

InvalidOperationException

在 中 options指定了无效的分区标识符时发生。

注解

首次尝试将事件排入队列时， SendEventBatchSucceededAsync 无法再更改 和 SendEventBatchFailedAsync 处理程序。