PartitionReceiver クラス

リファレンス

定義

名前空間:: Microsoft.Azure.EventHubs

アセンブリ:: Microsoft.Azure.EventHubs.dll

パッケージ:: Microsoft.Azure.EventHubs v4.3.2

ソース:: PartitionReceiver.cs

重要

一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。

これは、EventHub パーティションからの受信の論理的な表現です。

PartitionReceiver は、ConsumerGroup + パーティションの組み合わせに関連付けられています。エポックベースの PartitionReceiver (つまり PartitionReceiver.Epoch != 0) を作成する場合、ConsumerGroup + Partition コンボごとに複数のアクティブレシーバーを持つことはできません。 ConsumerGroup + パーティションごとに複数のレシーバーを非エポックレシーバーと組み合わせて使用できます。

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

type PartitionReceiver = class
    inherit ClientEntity

Public MustInherit Class PartitionReceiver
Inherits ClientEntity

継承: Object

ClientEntity
PartitionReceiver

コンストラクター

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

これは、EventHub パーティションからの受信の論理的な表現です。

フィールド

DefaultConsumerGroupName

既定のコンシューマーグループ名: $Default。

プロパティ

ClientId	クライアント ID を取得します。 (継承元 ClientEntity)
ConsumerGroupName	コンシューマーグループ名
Epoch	このレシーバーがパーティション所有権に現在使用しているエポック値を取得します。 null の値は、このレシーバーがエポックベースのレシーバーではないことを意味します。
EventHubClient	この PartitionReceiver が作成された EventHubClient。
EventPosition	これは、EventHub パーティションからの受信の論理的な表現です。 PartitionReceiver は、ConsumerGroup + パーティションの組み合わせに関連付けられています。エポックベースの PartitionReceiver (つまり PartitionReceiver.Epoch != 0) を作成する場合、ConsumerGroup + Partition コンボごとに複数のアクティブレシーバーを持つことはできません。 ConsumerGroup + パーティションごとに複数のレシーバーを非エポックレシーバーと組み合わせて使用できます。
Identifier	レシーバーの作成時に設定されたレシーバーの識別子を取得します。
IsClosed	クライアントオブジェクトが閉じているかどうかを表すブール値を返します。 (継承元 ClientEntity)
PartitionId	EventHub パーティション識別子を取得します。
PrefetchCount	受信側で構成されたプリフェッチ数を取得します。
ReceiverRuntimeMetricEnabled	レシーバーのランタイムメトリックが有効かどうかを示す値を取得します。
RegisteredPlugins	このクライアントの現在登録されているプラグインの一覧を取得します。 (継承元 ClientEntity)
RetryPolicy	ClientEntity のを RetryPolicy 取得します。 (継承元 ClientEntity)
RuntimeInfo	イベントハブの論理パーティションのおおよそのレシーバーランタイム情報を取得します。設定を有効にするには、とを参照してください ReceiverOptions 。 EnableReceiverRuntimeMetric

メソッド

Close()	ClientEntity を閉じます。 (継承元 ClientEntity)
CloseAsync()	に関連付けられているリソースを閉じて PartitionReceiver解放します。
OnCloseAsync()	これは、EventHub パーティションからの受信の論理的な表現です。 PartitionReceiver は、ConsumerGroup + パーティションの組み合わせに関連付けられています。エポックベースの PartitionReceiver (つまり PartitionReceiver.Epoch != 0) を作成する場合、ConsumerGroup + Partition コンボごとに複数のアクティブレシーバーを持つことはできません。 ConsumerGroup + パーティションごとに複数のレシーバーを非エポックレシーバーと組み合わせて使用できます。
OnReceiveAsync(Int32, TimeSpan)	これは、EventHub パーティションからの受信の論理的な表現です。 PartitionReceiver は、ConsumerGroup + パーティションの組み合わせに関連付けられています。エポックベースの PartitionReceiver (つまり PartitionReceiver.Epoch != 0) を作成する場合、ConsumerGroup + Partition コンボごとに複数のアクティブレシーバーを持つことはできません。 ConsumerGroup + パーティションごとに複数のレシーバーを非エポックレシーバーと組み合わせて使用できます。
OnRetryPolicyUpdate()	再試行ポリシーの更新に対してオーバーライドする派生エンティティ。 (継承元 ClientEntity)
OnSetReceiveHandler(IPartitionReceiveHandler, Boolean)	これは、EventHub パーティションからの受信の論理的な表現です。 PartitionReceiver は、ConsumerGroup + パーティションの組み合わせに関連付けられています。エポックベースの PartitionReceiver (つまり PartitionReceiver.Epoch != 0) を作成する場合、ConsumerGroup + Partition コンボごとに複数のアクティブレシーバーを持つことはできません。 ConsumerGroup + パーティションごとに複数のレシーバーを非エポックレシーバーと組み合わせて使用できます。
ReceiveAsync(Int32)	EventHub パーティションからの EventDataバッチを受信する
ReceiveAsync(Int32, TimeSpan)	個々の呼び出しで EventData待機時間を許可することで、EventHub パーティションからのバッチを受信します。
RegisterPlugin(EventHubsPlugin)	EventHubsPluginこのクライアントで使用するを登録します。 (継承元 ClientEntity)
SetReceiveHandler(IPartitionReceiveHandler, Boolean)	イベントを IPartitionReceiveHandler 処理するを設定します。
ThrowIfClosed()	クライアントオブジェクトが既に閉じている場合は、例外をスローします。 (継承元 ClientEntity)
UnregisterPlugin(String)	の登録を EventHubsPlugin解除します。 (継承元 ClientEntity)

適用対象

次の方法で共有