PartitionReceiver Clase

Definición

Espacio de nombres:

Microsoft.Azure.EventHubs

Ensamblado:

Microsoft.Azure.EventHubs.dll

Paquete:

Microsoft.Azure.EventHubs v4.3.2

Source:

PartitionReceiver.cs

Se trata de una representación lógica de la recepción de una partición de EventHub.

PartitionReceiver está vinculado a una combinación ConsumerGroup + Partition. Si va a crear un partitionReceiver basado en época (es decir, PartitionReceiver.Epoch != 0), no puede tener más de un receptor activo por grupo de consumidores + combinación de particiones. Puede tener varios receptores por combinación ConsumerGroup + Partition con receptores que no son de época.

public abstract class PartitionReceiver : Microsoft.Azure.EventHubs.ClientEntity

type PartitionReceiver = class
    inherit ClientEntity

Public MustInherit Class PartitionReceiver
Inherits ClientEntity

Herencia

Object

ClientEntity

PartitionReceiver

Constructores

PartitionReceiver(EventHubClient, String, String, EventPosition, Nullable<Int64>, ReceiverOptions)

Se trata de una representación lógica de la recepción de una partición de EventHub. PartitionReceiver está vinculado a una combinación ConsumerGroup + Partition. Si va a crear un partitionReceiver basado en época (es decir, PartitionReceiver.Epoch != 0), no puede tener más de un receptor activo por grupo de consumidores + combinación de particiones. Puede tener varios receptores por combinación ConsumerGroup + Partition con receptores que no son de época.

Campos

DefaultConsumerGroupName

Nombre predeterminado del grupo de consumidores: $Default.

Propiedades

ClientId	Obtiene el identificador de cliente. (Heredado de ClientEntity)
ConsumerGroupName	El nombre del grupo de consumidores
Epoch	Obtenga el valor de época que este receptor usa actualmente para la propiedad de la partición. Un valor null significa que este receptor no es un receptor basado en épocas.
EventHubClient	EventHubClient a partir de la que se creó PartitionReceiver.
EventPosition	Se trata de una representación lógica de la recepción de una partición de EventHub. PartitionReceiver está vinculado a una combinación ConsumerGroup + Partition. Si va a crear un partitionReceiver basado en época (es decir, PartitionReceiver.Epoch != 0), no puede tener más de un receptor activo por grupo de consumidores + combinación de particiones. Puede tener varios receptores por combinación ConsumerGroup + Partition con receptores que no son de época.
Identifier	Obtiene el identificador de un receptor que se estableció durante la creación del receptor.
IsClosed	Devuelve un valor booleano que representa si el objeto de cliente está cerrado o no. (Heredado de ClientEntity)
PartitionId	Obtenga el identificador de partición de EventHub.
PrefetchCount	Obtiene el número de capturas previas configurado en el receptor.
ReceiverRuntimeMetricEnabled	Obtiene un valor que indica si la métrica en tiempo de ejecución de un receptor está habilitada.
RegisteredPlugins	Obtiene una lista de complementos registrados actualmente para este cliente. (Heredado de ClientEntity)
RetryPolicy	Obtiene para RetryPolicy ClientEntity. (Heredado de ClientEntity)
RuntimeInfo	Obtiene la información aproximada del tiempo de ejecución del receptor para una partición lógica de un centro de eventos. Para habilitar la configuración, consulte ReceiverOptions y EnableReceiverRuntimeMetric

Métodos

Close()	Cierra ClientEntity. (Heredado de ClientEntity)
CloseAsync()	Cierra y libera los recursos asociados a PartitionReceiver.
OnCloseAsync()	Se trata de una representación lógica de la recepción de una partición de EventHub. PartitionReceiver está vinculado a una combinación ConsumerGroup + Partition. Si va a crear un partitionReceiver basado en época (es decir, PartitionReceiver.Epoch != 0), no puede tener más de un receptor activo por grupo de consumidores + combinación de particiones. Puede tener varios receptores por combinación ConsumerGroup + Partition con receptores que no son de época.
OnReceiveAsync(Int32, TimeSpan)	Se trata de una representación lógica de la recepción de una partición de EventHub. PartitionReceiver está vinculado a una combinación ConsumerGroup + Partition. Si va a crear un partitionReceiver basado en época (es decir, PartitionReceiver.Epoch != 0), no puede tener más de un receptor activo por grupo de consumidores + combinación de particiones. Puede tener varios receptores por combinación ConsumerGroup + Partition con receptores que no son de época.
OnRetryPolicyUpdate()	Entidad derivada que se va a invalidar para las actualizaciones de directivas de reintento. (Heredado de ClientEntity)
OnSetReceiveHandler(IPartitionReceiveHandler, Boolean)	Se trata de una representación lógica de la recepción de una partición de EventHub. PartitionReceiver está vinculado a una combinación ConsumerGroup + Partition. Si va a crear un partitionReceiver basado en época (es decir, PartitionReceiver.Epoch != 0), no puede tener más de un receptor activo por grupo de consumidores + combinación de particiones. Puede tener varios receptores por combinación ConsumerGroup + Partition con receptores que no son de época.
ReceiveAsync(Int32)	Recepción de un lote de EventDatade una partición de EventHub
ReceiveAsync(Int32, TimeSpan)	Reciba un lote de de una partición de EventHub al permitir el tiempo de EventDataespera en cada llamada individual.
RegisterPlugin(EventHubsPlugin)	Registra un EventHubsPlugin objeto que se va a usar con este cliente. (Heredado de ClientEntity)
SetReceiveHandler(IPartitionReceiveHandler, Boolean)	Establece para IPartitionReceiveHandler procesar eventos.
ThrowIfClosed()	Produce una excepción si el objeto de cliente ya está cerrado. (Heredado de ClientEntity)
UnregisterPlugin(String)	Anula el registro de un EventHubsPluginobjeto . (Heredado de ClientEntity)

Consulte también

• CreateEpochReceiver(String, String, EventPosition, Int64, ReceiverOptions)
• CreateReceiver(String, String, EventPosition, ReceiverOptions)