PartitionReceiver Clase

Definición

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
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)

Se aplica a

Consulte también