你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。
PartitionReceiver 类
定义
重要
一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。 对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。
这是从 EventHub 分区接收的逻辑表示形式。
PartitionReceiver 绑定到 ConsumerGroup + Partition 组合。 如果要创建基于 epoch 的 PartitionReceiver (即 PartitionReceiver.Epoch ！= 0) 每个 ConsumerGroup + 分区组合不能有多个活动接收器。 每个 ConsumerGroup + Partition 组合可以有多个具有非纪元接收器的接收方。
public abstract class PartitionReceiver : Microsoft.Azure.EventHubs.ClientEntitytype PartitionReceiver = class
inherit ClientEntityPublic MustInherit Class PartitionReceiver
Inherits ClientEntity- 继承
构造函数
| PartitionReceiver(EventHubClient, String, String, EventPosition, Nullable<Int64>, ReceiverOptions) |
这是从 EventHub 分区接收的逻辑表示形式。 PartitionReceiver 绑定到 ConsumerGroup + Partition 组合。 如果要创建基于 epoch 的 PartitionReceiver (即 PartitionReceiver.Epoch ！= 0) 每个 ConsumerGroup + 分区组合不能有多个活动接收器。 每个 ConsumerGroup + Partition 组合可以有多个具有非纪元接收器的接收方。 |
字段
| DefaultConsumerGroupName |
默认使用者组名称：$Default。 |
属性
| ClientId |
获取客户端 ID。 (继承自 ClientEntity) |
| ConsumerGroupName |
使用者组名称 |
| Epoch |
获取此接收方当前用于分区所有权的纪元值。 null 值表示此接收器不是基于纪元的接收方。 |
| EventHubClient |
EventHubClient 此 PartitionReceiver 是从中创建的。 |
| EventPosition |
这是从 EventHub 分区接收的逻辑表示形式。 PartitionReceiver 绑定到 ConsumerGroup + Partition 组合。 如果要创建基于 epoch 的 PartitionReceiver (即 PartitionReceiver.Epoch ！= 0) 每个 ConsumerGroup + 分区组合不能有多个活动接收器。 每个 ConsumerGroup + Partition 组合可以有多个具有非纪元接收器的接收方。 |
| Identifier |
获取在创建接收方期间设置的接收方的标识符。 |
| IsClosed |
返回一个布尔值，该值表示客户端对象是否关闭。 (继承自 ClientEntity) |
| PartitionId |
获取 EventHub 分区标识符。 |
| PrefetchCount |
在接收方上配置预提取计数。 |
| ReceiverRuntimeMetricEnabled |
获取一个值，该值指示是否启用接收方的运行时指标。 |
| RegisteredPlugins |
获取此客户端当前注册的插件的列表。 (继承自 ClientEntity) |
| RetryPolicy |
获取 RetryPolicy ClientEntity 的 。 (继承自 ClientEntity) |
| RuntimeInfo |
获取事件中心的逻辑分区的近似接收方运行时信息。 若要启用设置，请参阅 ReceiverOptions 和 EnableReceiverRuntimeMetric |
方法
| Close() |
关闭 ClientEntity。 (继承自 ClientEntity) |
| CloseAsync() |
关闭并释放与 关联的 PartitionReceiver资源。 |
| OnCloseAsync() |
这是从 EventHub 分区接收的逻辑表示形式。 PartitionReceiver 绑定到 ConsumerGroup + Partition 组合。 如果要创建基于 epoch 的 PartitionReceiver (即 PartitionReceiver.Epoch ！= 0) 每个 ConsumerGroup + 分区组合不能有多个活动接收器。 每个 ConsumerGroup + Partition 组合可以有多个具有非纪元接收器的接收方。 |
| OnReceiveAsync(Int32, TimeSpan) |
这是从 EventHub 分区接收的逻辑表示形式。 PartitionReceiver 绑定到 ConsumerGroup + Partition 组合。 如果要创建基于 epoch 的 PartitionReceiver (即 PartitionReceiver.Epoch ！= 0) 每个 ConsumerGroup + 分区组合不能有多个活动接收器。 每个 ConsumerGroup + Partition 组合可以有多个具有非纪元接收器的接收方。 |
| OnRetryPolicyUpdate() |
要替代重试策略更新的派生实体。 (继承自 ClientEntity) |
| OnSetReceiveHandler(IPartitionReceiveHandler, Boolean) |
这是从 EventHub 分区接收的逻辑表示形式。 PartitionReceiver 绑定到 ConsumerGroup + Partition 组合。 如果要创建基于 epoch 的 PartitionReceiver (即 PartitionReceiver.Epoch ！= 0) 每个 ConsumerGroup + 分区组合不能有多个活动接收器。 每个 ConsumerGroup + Partition 组合可以有多个具有非纪元接收器的接收方。 |
| ReceiveAsync(Int32) |
从 EventHub 分区接收一批 EventData的 |
| ReceiveAsync(Int32, TimeSpan) |
通过允许每个单独调用的等待时间，从 EventHub 分区接收一批 EventData。 |
| RegisterPlugin(EventHubsPlugin) |
EventHubsPlugin注册要用于此客户端的 。 (继承自 ClientEntity) |
| SetReceiveHandler(IPartitionReceiveHandler, Boolean) |
IPartitionReceiveHandler设置 以处理事件。 |
| ThrowIfClosed() |
如果客户端对象已关闭，则引发异常。 (继承自 ClientEntity) |
| UnregisterPlugin(String) |
取消注册 EventHubsPlugin。 (继承自 ClientEntity) |
