PartitionReceiver Classe

Definição

Essa é uma representação lógica de recebimento de uma partição do EventHub.

Um PartitionReceiver está vinculado a uma combinação ConsumerGroup + Partition. Se você estiver criando uma partição baseada em épocaReceiver (ou seja, PartitionReceiver.Epoch != 0), não poderá ter mais de um receptor ativo por combinação ConsumerGroup + Partition. Você pode ter vários receptores por combinação ConsumerGroup + Partição com receptores que não são épocas.

public abstract class PartitionReceiver : Microsoft.Azure.EventHubs.ClientEntity
type PartitionReceiver = class
    inherit ClientEntity
Public MustInherit Class PartitionReceiver
Inherits ClientEntity
Herança
PartitionReceiver

Construtores

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

Essa é uma representação lógica de recebimento de uma partição do EventHub.

Um PartitionReceiver está vinculado a uma combinação ConsumerGroup + Partition. Se você estiver criando uma partição baseada em épocaReceiver (ou seja, PartitionReceiver.Epoch != 0), não poderá ter mais de um receptor ativo por combinação ConsumerGroup + Partition. Você pode ter vários receptores por combinação ConsumerGroup + Partição com receptores que não são épocas.

Campos

DefaultConsumerGroupName

O nome do grupo de consumidores padrão: $Default.

Propriedades

ClientId

Obtém a ID do cliente.

(Herdado de ClientEntity)
ConsumerGroupName

O Nome do Grupo de Consumidores

Epoch

Obtenha o valor de época que esse receptor está usando atualmente para a propriedade da partição.

Um valor nulo significa que esse receptor não é um receptor baseado em época.

EventHubClient

O EventHubClient do qual partitionReceiver foi criado.

EventPosition

Essa é uma representação lógica de recebimento de uma partição do EventHub.

Um PartitionReceiver está vinculado a uma combinação ConsumerGroup + Partition. Se você estiver criando uma partição baseada em épocaReceiver (ou seja, PartitionReceiver.Epoch != 0), não poderá ter mais de um receptor ativo por combinação ConsumerGroup + Partition. Você pode ter vários receptores por combinação ConsumerGroup + Partição com receptores que não são épocas.

Identifier

Obtém o identificador de um receptor que foi definido durante a criação do receptor.

IsClosed

Retorna um booliano que representa se o objeto cliente está fechado ou não.

(Herdado de ClientEntity)
PartitionId

Obtenha o identificador de partição do EventHub.

PrefetchCount

Obter Contagem de Pré-busca configurada no Receptor.

ReceiverRuntimeMetricEnabled

Obtém um valor que indica se a métrica de runtime de um receptor está habilitada.

RegisteredPlugins

Obtém uma lista de plug-ins registrados no momento para este Cliente.

(Herdado de ClientEntity)
RetryPolicy

Obtém o RetryPolicy para a ClientEntity.

(Herdado de ClientEntity)
RuntimeInfo

Obtém as informações aproximadas de runtime do receptor para uma partição lógica de um Hub de Eventos. Para habilitar a configuração, consulte ReceiverOptions e EnableReceiverRuntimeMetric

Métodos

Close()

Fecha a ClientEntity.

(Herdado de ClientEntity)
CloseAsync()

Fecha e libera recursos associados PartitionReceivera .

OnCloseAsync()

Essa é uma representação lógica de recebimento de uma partição do EventHub.

Um PartitionReceiver está vinculado a uma combinação ConsumerGroup + Partition. Se você estiver criando uma partição baseada em épocaReceiver (ou seja, PartitionReceiver.Epoch != 0), não poderá ter mais de um receptor ativo por combinação ConsumerGroup + Partition. Você pode ter vários receptores por combinação ConsumerGroup + Partição com receptores que não são épocas.

OnReceiveAsync(Int32, TimeSpan)

Essa é uma representação lógica de recebimento de uma partição do EventHub.

Um PartitionReceiver está vinculado a uma combinação ConsumerGroup + Partition. Se você estiver criando uma partição baseada em épocaReceiver (ou seja, PartitionReceiver.Epoch != 0), não poderá ter mais de um receptor ativo por combinação ConsumerGroup + Partition. Você pode ter vários receptores por combinação ConsumerGroup + Partição com receptores que não são épocas.

OnRetryPolicyUpdate()

Entidade derivada a ser substituída por atualizações de política de repetição.

(Herdado de ClientEntity)
OnSetReceiveHandler(IPartitionReceiveHandler, Boolean)

Essa é uma representação lógica de recebimento de uma partição do EventHub.

Um PartitionReceiver está vinculado a uma combinação ConsumerGroup + Partition. Se você estiver criando uma partição baseada em épocaReceiver (ou seja, PartitionReceiver.Epoch != 0), não poderá ter mais de um receptor ativo por combinação ConsumerGroup + Partition. Você pode ter vários receptores por combinação ConsumerGroup + Partição com receptores que não são épocas.

ReceiveAsync(Int32)

Receber um lote de EventData's de uma partição do EventHub

ReceiveAsync(Int32, TimeSpan)

Receba um lote de EventData's de uma partição eventHub permitindo tempo de espera em cada chamada individual.

RegisterPlugin(EventHubsPlugin)

Registra um EventHubsPlugin a ser usado com esse cliente.

(Herdado de ClientEntity)
SetReceiveHandler(IPartitionReceiveHandler, Boolean)

Define o IPartitionReceiveHandler para processar eventos.

ThrowIfClosed()

Gera uma exceção se o objeto cliente já estiver fechado.

(Herdado de ClientEntity)
UnregisterPlugin(String)

Cancela o registro de um EventHubsPlugin.

(Herdado de ClientEntity)

Aplica-se a

Confira também