你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
EventProcessorOptions 类
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
定义向 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 方法。 当没有与引发活动关联的事件处理器,或者无法创建事件处理器时,将调用此处理程序。 |