EventProcessor<TPartition>.OnPartitionProcessingStoppedAsync メソッド

  • リファレンス

定義

名前空間:
Azure.Messaging.EventHubs.Primitives
アセンブリ:
Azure.Messaging.EventHubs.dll
パッケージ:
Azure.Messaging.EventHubs v5.11.3
パッケージ:
Azure.Messaging.EventHubs v5.12.0-beta.1
ソース:
EventProcessor.cs
ソース:
EventProcessor.cs

パーティションの処理が停止しているときに必要なタスクを実行します。 これは通常、パーティションが別のイベント プロセッサ インスタンスによって要求された場合、または現在のイベント プロセッサ インスタンスがシャットダウンされるときに発生します。

protected virtual System.Threading.Tasks.Task OnPartitionProcessingStoppedAsync (TPartition partition, Azure.Messaging.EventHubs.Processor.ProcessingStoppedReason reason, System.Threading.CancellationToken cancellationToken);
abstract member OnPartitionProcessingStoppedAsync : 'Partition * Azure.Messaging.EventHubs.Processor.ProcessingStoppedReason * System.Threading.CancellationToken -> System.Threading.Tasks.Task
override this.OnPartitionProcessingStoppedAsync : 'Partition * Azure.Messaging.EventHubs.Processor.ProcessingStoppedReason * System.Threading.CancellationToken -> System.Threading.Tasks.Task
Protected Overridable Function OnPartitionProcessingStoppedAsync (partition As TPartition, reason As ProcessingStoppedReason, cancellationToken As CancellationToken) As Task

パラメーター

partition
TPartition

処理が停止されているパーティションのコンテキスト。

reason
ProcessingStoppedReason

パーティションの処理が停止している理由。

cancellationToken
CancellationToken

CancellationToken処理を取り消す要求を通知するインスタンス。 これは、通常の状況では通知されるとは限らず、プロセッサで回復不可能なエラーが発生した場合にのみ発生します。

戻り値

Task

注釈

プロセッサの状態は、このメソッド内から直接管理することはお勧めしません。プロセッサの起動または停止を要求すると、特に呼び出しの同期形式を使用している場合にデッドロック シナリオが発生する可能性があります。

各クローズが独立している場合、このメソッドは同時に呼び出されます。 呼び出しに制限時間は適用されません。実装では、必要に応じて実行時間の長い操作と再試行を実行しても安全です。 このハンドラーは、関連付けられたパーティションの処理に影響を与えるものではありません。また、パーティションの処理が再開されるか、新しいホストに移行される前に実行が完了する保証はありません。

適用対象