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

EventProcessorOptions 类

定义

定义向 EventHubConsumerGroup 注册 IEventProcessor 接口时的运行时选项。 这也是从对象使用的 EventProcessorHost IEventProcessor 实例捕获异常的机制。

public sealed class EventProcessorOptions
type EventProcessorOptions = class
Public NotInheritable Class EventProcessorOptions
继承
EventProcessorOptions

构造函数

EventProcessorOptions()

创建一个新的 EventProcessorOptions 对象。

属性

DefaultOptions

返回一个 EventProcessorOptions 实例,其中所有选项都设置为默认值。 默认值为:

MaxBatchSize:10

ReceiveTimeOut:1 分钟

PrefetchCount:300

InitialOffsetProvider:使用最后一个偏移点或 StartOfStream

InvokeProcessorAfterReceiveTimeout: false

EnableReceiverRuntimeMetric

获取或设置一个值,该值指示是否启用接收方的运行时指标。

InitialOffsetProvider

获取或设置一个委托,该委托用于获取给定分区的初始位置以创建 PartitionReceiver。 通过传入 PartitionId 调用委托,然后用户可以返回 PartitionReceiver 以接收消息。 仅当找不到关联分区的检查点时,才使用此方法。

InvokeProcessorAfterReceiveTimeout

返回当接收超时 (true) 或不 (false) 时,EventProcessorHost 是否会调用 IEventProcessor.OnEvents (null) 。

MaxBatchSize

返回将使用 IEventProcessor.ProcessEventsAsync 调用的事件批的最大大小

PrefetchCount

获取或设置基础客户端的当前预提取计数。 默认值为 300。

ReceiveTimeout

获取或设置接收操作的超时长度。

WebProxy

获取或设置 Web 代理。 仅当传输类型设置为 AmqpWebSocket 时,代理才适用。

方法

SetExceptionHandler(Action<ExceptionReceivedEventArgs>)

设置接收常规异常通知的处理程序。

处理来自特定事件中心分区的事件时发生的异常将传递到该分区的事件处理器的 onError 方法。 当没有与引发活动关联的事件处理器,或者无法创建事件处理器时,将调用此处理程序。

适用于