PartitionReceiver Klasse

Referenz

Definition

Namespace:: Microsoft.Azure.EventHubs

Assembly:: Microsoft.Azure.EventHubs.dll

Paket:: Microsoft.Azure.EventHubs v4.3.2

Quelle:: PartitionReceiver.cs

Wichtig

Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.

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: Object

ClientEntity
PartitionReceiver

Konstruktoren

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

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

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:

Share via