IEventProcessor インターフェイス
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
イベント プロセッサ クラスによって実装される必要があるインターフェイス。
イベント プロセッサ クラスの特定のインスタンスは、1 つのイベント ハブの 1 つのパーティションからのイベントのみを処理します。 一部のパラメーターは変更される可能性があるため、PartitionContext はイベント プロセッサの呼び出しごとに提供されますが、常に同じパーティションになります。
EventProcessorHost はマルチスレッドですが、OnError() を除き、イベント プロセッサ クラスの特定のインスタンスへの呼び出しはシリアル化されます。 OnOpen() は最初に呼び出され、OnEvents() は 0 回以上呼び出されます。 イベント プロセッサをシャットダウンする必要がある場合、障害が発生したか、パーティションのリースが失われたか、プロセッサ ホスト全体がシャットダウンされているかに関係なく、OnClose() は最後の OnEvents() 呼び出しが返された後に呼び出されます。
OnEvents() または OnClose() の実行中に OnError() を呼び出す可能性があります。 デッドロックの可能性を回避するために、同期は試行されません。
public interface IEventProcessortype IEventProcessor = interfacePublic Interface IEventProcessorメソッド
| CloseAsync(PartitionContext, CloseReason) |
イベント プロセッサが停止していることを示すために、プロセッサ ホストによって呼び出されます。 |
| OpenAsync(PartitionContext) |
イベント プロセッサを初期化するためにプロセッサ ホストによって呼び出されます。 |
| ProcessErrorAsync(PartitionContext, Exception) |
受信中に基になるクライアントでエラーが発生したときに呼び出されます。 EventProcessorHost はエラーからの回復とメッセージのポンプ処理を引き続き行うので、コードからのアクションは必要ありません。 このメソッドは、情報提供を目的として提供されます。 |
| ProcessEventsAsync(PartitionContext, IEnumerable<EventData>) |
イベントのバッチが到着したときにプロセッサ ホストによって呼び出されます。 ここで、イベント プロセッサの実際の作業が行われます。 |
適用対象
Azure SDK for .NET