EventProcessorClient.ClaimOwnershipAsync メソッド

定義

名前空間:

Azure.Messaging.EventHubs

アセンブリ:

Azure.Messaging.EventHubs.Processor.dll

パッケージ:

Azure.Messaging.EventHubs.Processor v5.11.3

ソース:

EventProcessorClient.cs

処理のために、指定されたパーティションの所有権の要求を試みます。 このメソッドは、負荷分散によって使用され、イベント プロセッサ インスタンスが、特定のイベント ハブとコンシューマー グループのペアのパーティションを処理する責任をアクティブなイベント プロセッサ間で分散できるようにします。

protected override System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership>> ClaimOwnershipAsync (System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership> desiredOwnership, System.Threading.CancellationToken cancellationToken);

override this.ClaimOwnershipAsync : seq<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<seq<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership>>

Protected Overrides Function ClaimOwnershipAsync (desiredOwnership As IEnumerable(Of EventProcessorPartitionOwnership), cancellationToken As CancellationToken) As Task(Of IEnumerable(Of EventProcessorPartitionOwnership))

パラメーター

desiredOwnership

IEnumerable<EventProcessorPartitionOwnership>

イベント プロセッサ インスタンスで必要なパーティション所有権のセット。これは、処理の責任を要求しようとするパーティションのセットです。

cancellationToken

CancellationToken

CancellationToken処理を取り消す要求を通知する インスタンス。 これは、プロセッサがシャットダウンするときに発生する可能性が最も高いです。

戻り値

Task<IEnumerable<EventProcessorPartitionOwnership>>

正常に要求されたパーティションの所有権レコードのセット。これは、これらのパーティションの desiredOwnership または のサブセットである必要があります。