EventProcessorOptions クラス

定義

名前空間:

Microsoft.Azure.EventHubs.Processor

アセンブリ:

Microsoft.Azure.EventHubs.Processor.dll

パッケージ:

Microsoft.Azure.EventHubs.Processor v4.3.2

ソース:

EventProcessorOptions.cs

EventHubConsumerGroup にインターフェイスを IEventProcessor 登録するときのランタイム オプションを定義します。 これは、オブジェクトによって EventProcessorHost 使用される IEventProcessor インスタンスから例外をキャッチするためのメカニズムでもあります。

public sealed class EventProcessorOptions

type EventProcessorOptions = class

Public NotInheritable Class EventProcessorOptions

継承

Object

EventProcessorOptions

コンストラクター

EventProcessorOptions()

新しい EventProcessorOptions オブジェクトを作成します。

プロパティ

DefaultOptions	すべてのオプションが既定値に設定された EventProcessorOptions インスタンスを返します。 既定値は次のとおりです。 MaxBatchSize: 10 ReceiveTimeOut: 1 分 PrefetchCount: 300 InitialOffsetProvider: チェックポイントが設定された最後のオフセットまたは StartOfStream を使用します InvokeProcessorAfterReceiveTimeout: false
EnableReceiverRuntimeMetric	レシーバーのランタイム メトリックが有効かどうかを示す値を取得または設定します。
InitialOffsetProvider	を作成 PartitionReceiverする特定のパーティションの初期位置を取得するために使用されるデリゲートを取得または設定します。 デリゲートは PartitionId を渡すことによって呼び出され、ユーザーはメッセージを受信するために を返 PartitionReceiver すことができます。 これは、関連付けられたパーティションのチェックポイントが見つからない場合にのみ使用されます。
InvokeProcessorAfterReceiveTimeout	受信タイムアウトが発生した場合に EventProcessorHost が IEventProcessor.OnEvents(null) を呼び出すかどうかを返します (true) かどうか (false)。
MaxBatchSize	IEventProcessor.ProcessEventsAsync が呼び出されるイベント バッチの最大サイズを返します。
PrefetchCount	基になるクライアントの現在のプリフェッチ数を取得または設定します。 既定値は 300 です。
ReceiveTimeout	受信操作のタイムアウト長を取得または設定します。
WebProxy	Web プロキシを取得または設定します。 プロキシは、トランスポートの種類が AmqpWebSocket に設定されている場合にのみ適用されます。

メソッド

SetExceptionHandler(Action<ExceptionReceivedEventArgs>)

一般的な例外の通知を受け取るハンドラーを設定します。 特定の Event Hub パーティションからのイベントの処理中に発生する例外は、そのパーティションのイベント プロセッサの onError メソッドに配信されます。 このハンドラーは、スローアクティビティに関連付けられているイベント プロセッサがない場合、またはイベント プロセッサを作成できなかった場合に呼び出されます。