IEventProcessor インターフェイス

定義

名前空間:

Microsoft.Azure.EventHubs.Processor

アセンブリ:

Microsoft.Azure.EventHubs.Processor.dll

パッケージ:

Microsoft.Azure.EventHubs.Processor v4.3.2

イベント プロセッサ クラスによって実装される必要があるインターフェイス。

イベント プロセッサ クラスの特定のインスタンスは、1 つのイベント ハブの 1 つのパーティションからのイベントのみを処理します。 一部のパラメーターは変更される可能性があるため、PartitionContext はイベント プロセッサの呼び出しごとに提供されますが、常に同じパーティションになります。

EventProcessorHost はマルチスレッドですが、OnError() を除き、イベント プロセッサ クラスの特定のインスタンスへの呼び出しはシリアル化されます。 OnOpen() は最初に呼び出され、OnEvents() は 0 回以上呼び出されます。 イベント プロセッサをシャットダウンする必要がある場合、障害が発生したか、パーティションのリースが失われたか、プロセッサ ホスト全体がシャットダウンされているかに関係なく、OnClose() は最後の OnEvents() 呼び出しが返された後に呼び出されます。

OnEvents() または OnClose() の実行中に OnError() を呼び出す可能性があります。 デッドロックの可能性を回避するために、同期は試行されません。

public interface IEventProcessor

type IEventProcessor = interface

Public Interface IEventProcessor

メソッド

CloseAsync(PartitionContext, CloseReason)	イベント プロセッサが停止していることを示すために、プロセッサ ホストによって呼び出されます。
OpenAsync(PartitionContext)	イベント プロセッサを初期化するためにプロセッサ ホストによって呼び出されます。
ProcessErrorAsync(PartitionContext, Exception)	受信中に基になるクライアントでエラーが発生したときに呼び出されます。 EventProcessorHost はエラーからの回復とメッセージのポンプ処理を引き続き行うので、コードからのアクションは必要ありません。 このメソッドは、情報提供を目的として提供されます。
ProcessEventsAsync(PartitionContext, IEnumerable<EventData>)	イベントのバッチが到着したときにプロセッサ ホストによって呼び出されます。 ここで、イベント プロセッサの実際の作業が行われます。