Freigeben über


PartitionReceiver Klasse

Definition

Dies ist eine logische Darstellung des Empfangens von einer EventHub-Partition.

Ein PartitionReceiver ist an eine ConsumerGroup + Partition-Kombination gebunden. Wenn Sie einen epochenbasierten PartitionReceiver (d. h. PartitionReceiver.Epoch != 0) erstellen, können Sie nicht mehr als einen aktiven Empfänger pro ConsumerGroup + Partitionskombination haben. Sie können mehrere Empfänger pro ConsumerGroup + Partitionskombination mit Nicht-Epochenempfängern verwenden.

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

Konstruktoren

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

Dies ist eine logische Darstellung des Empfangens von einer EventHub-Partition.

Ein PartitionReceiver ist an eine ConsumerGroup + Partition-Kombination gebunden. Wenn Sie einen epochenbasierten PartitionReceiver (d. h. PartitionReceiver.Epoch != 0) erstellen, können Sie nicht mehr als einen aktiven Empfänger pro ConsumerGroup + Partitionskombination haben. Sie können mehrere Empfänger pro ConsumerGroup + Partitionskombination mit Nicht-Epochenempfängern verwenden.

Felder

DefaultConsumerGroupName

Der Standardbenutzergruppenname: $Default.

Eigenschaften

ClientId

Ruft die Client-ID ab.

(Geerbt von ClientEntity)
ConsumerGroupName

Der Name der Consumergruppe

Epoch

Rufen Sie den Epochenwert ab, den dieser Empfänger derzeit für den Partitionsbesitz verwendet.

Der Wert NULL bedeutet, dass dieser Empfänger kein epochenbasierter Empfänger ist.

EventHubClient

Der EventHubClient, aus dem dieser PartitionReceiver erstellt wurde.

EventPosition

Dies ist eine logische Darstellung des Empfangens von einer EventHub-Partition.

Ein PartitionReceiver ist an eine ConsumerGroup + Partition-Kombination gebunden. Wenn Sie einen epochenbasierten PartitionReceiver (d. h. PartitionReceiver.Epoch != 0) erstellen, können Sie nicht mehr als einen aktiven Empfänger pro ConsumerGroup + Partitionskombination haben. Sie können mehrere Empfänger pro ConsumerGroup + Partitionskombination mit Nicht-Epochenempfängern verwenden.

Identifier

Ruft den Bezeichner eines Empfängers ab, der während der Erstellung des Empfängers festgelegt wurde.

IsClosed

Gibt einen booleschen Wert zurück, der angibt, ob das Clientobjekt geschlossen ist oder nicht.

(Geerbt von ClientEntity)
PartitionId

Rufen Sie den EventHub-Partitionsbezeichner ab.

PrefetchCount

Rufen Sie die prefetch Count (Prefetch Count) ab, die für den Empfänger konfiguriert ist.

ReceiverRuntimeMetricEnabled

Ruft einen Wert ab, der angibt, ob die Laufzeitmetrik eines Empfängers aktiviert ist.

RegisteredPlugins

Ruft eine Liste der derzeit registrierten Plug-Ins für diesen Client ab.

(Geerbt von ClientEntity)
RetryPolicy

Ruft die RetryPolicy für clientEntity ab.

(Geerbt von ClientEntity)
RuntimeInfo

Ruft die ungefähren Informationen zur Empfängerlaufzeit für eine logische Partition eines Event Hubs ab. Informationen zum Aktivieren der Einstellung finden Sie unter ReceiverOptions und EnableReceiverRuntimeMetric

Methoden

Close()

Schließt clientEntity.

(Geerbt von ClientEntity)
CloseAsync()

Schließt und gibt ressourcen frei, die zugeordnet sind PartitionReceiver.

OnCloseAsync()

Dies ist eine logische Darstellung des Empfangens von einer EventHub-Partition.

Ein PartitionReceiver ist an eine ConsumerGroup + Partition-Kombination gebunden. Wenn Sie einen epochenbasierten PartitionReceiver (d. h. PartitionReceiver.Epoch != 0) erstellen, können Sie nicht mehr als einen aktiven Empfänger pro ConsumerGroup + Partitionskombination haben. Sie können mehrere Empfänger pro ConsumerGroup + Partitionskombination mit Nicht-Epochenempfängern verwenden.

OnReceiveAsync(Int32, TimeSpan)

Dies ist eine logische Darstellung des Empfangens von einer EventHub-Partition.

Ein PartitionReceiver ist an eine ConsumerGroup + Partition-Kombination gebunden. Wenn Sie einen epochenbasierten PartitionReceiver (d. h. PartitionReceiver.Epoch != 0) erstellen, können Sie nicht mehr als einen aktiven Empfänger pro ConsumerGroup + Partitionskombination haben. Sie können mehrere Empfänger pro ConsumerGroup + Partitionskombination mit Nicht-Epochenempfängern verwenden.

OnRetryPolicyUpdate()

Abgeleitete Entität, die für Wiederholungsrichtlinienupdates außer Kraft gesetzt werden soll.

(Geerbt von ClientEntity)
OnSetReceiveHandler(IPartitionReceiveHandler, Boolean)

Dies ist eine logische Darstellung des Empfangens von einer EventHub-Partition.

Ein PartitionReceiver ist an eine ConsumerGroup + Partition-Kombination gebunden. Wenn Sie einen epochenbasierten PartitionReceiver (d. h. PartitionReceiver.Epoch != 0) erstellen, können Sie nicht mehr als einen aktiven Empfänger pro ConsumerGroup + Partitionskombination haben. Sie können mehrere Empfänger pro ConsumerGroup + Partitionskombination mit Nicht-Epochenempfängern verwenden.

ReceiveAsync(Int32)

Empfangen eines Batches von EventData"s" von einer EventHub-Partition

ReceiveAsync(Int32, TimeSpan)

Erhalten Sie einen Batch von EventData"s" von einer EventHub-Partition, indem Sie wartezeiten für jeden einzelnen Aufruf zulassen.

RegisterPlugin(EventHubsPlugin)

Registriert eine EventHubsPlugin , die mit diesem Client verwendet werden soll.

(Geerbt von ClientEntity)
SetReceiveHandler(IPartitionReceiveHandler, Boolean)

Legt fest IPartitionReceiveHandler , dass Ereignisse verarbeitet.

ThrowIfClosed()

Löst eine Ausnahme aus, wenn das Clientobjekt bereits geschlossen ist.

(Geerbt von ClientEntity)
UnregisterPlugin(String)

Hebt die Registrierung eines auf EventHubsPlugin.

(Geerbt von ClientEntity)

Gilt für:

Weitere Informationen