EventProcessorHost クラス

定義

名前空間:

Microsoft.ServiceBus.Messaging

アセンブリ:

Microsoft.ServiceBus.Messaging.EventProcessorHost.dll

パッケージ:

Microsoft.Azure.ServiceBus.EventProcessorHost v5.0.1

EventHub メッセージを処理するための非常にシンプルなホスト。 EventProcessorHost インスタンス間で EventHub パーティションを分散する処理を行います。 EventHub で各パーティションに対して Azure ブロック BLOB を作成し、これらの BLOB を使用してパーティションのリースを管理します。 すべての EventProcessorHost インスタンスは、次の 2 つのタスクを実行しています。1) リースの更新: ホストが現在所有しているリースを追跡し、リースの更新を継続的に続けます。 2) リースの取得: 各インスタンスは、すべてのリース BLOB を継続的にポーリングしてチェックし、システムがバランスのとれた状態にするために取得する必要があるリースがあるかどうかを確認します。 クライアント アプリケーションでは、プロセッサの実装を実装 IEventProcessor し、EventProcessorHost に登録する必要があります。

public class EventProcessorHost : IDisposable

type EventProcessorHost = class
    interface IDisposable

Public Class EventProcessorHost
Implements IDisposable

継承

Object

EventProcessorHost

実装

IDisposable

コンストラクター

EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>)	EventProcessorHost の新しいインスタンスを作成します。
EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>, String, String)	EventProcessorHost の新しいインスタンスを作成します。
EventProcessorHost(String, String, String, String)	EventProcessorHost の新しいインスタンスを作成します。
EventProcessorHost(String, String, String, String, String)	EventProcessorHost クラスの新しいインスタンスを初期化します。
EventProcessorHost(String, String, String, String, String, String, String)	EventProcessorHost クラスの新しいインスタンスを初期化します。

プロパティ

HostName	インスタンスの一意の名前であるホスト名を EventProcessorHost 取得します。
PartitionManagerOptions	オブジェクトによって使用されるインスタンスをPartitionManagerOptionsEventProcessorHost取得または設定します。

メソッド

Dispose()	EventHub メッセージを処理するための非常にシンプルなホスト。 EventProcessorHost インスタンス間で EventHub パーティションを分散する処理を行います。 EventHub で各パーティションに対して Azure ブロック BLOB を作成し、これらの BLOB を使用してパーティションのリースを管理します。 すべての EventProcessorHost インスタンスは、次の 2 つのタスクを実行しています。1) リースの更新: ホストが現在所有しているリースを追跡し、リースの更新を継続的に続けます。 2) リースの取得: 各インスタンスは、すべてのリース BLOB を継続的にポーリングしてチェックし、システムがバランスのとれた状態にするために取得する必要があるリースがあるかどうかを確認します。 クライアント アプリケーションでは、プロセッサの実装を実装 IEventProcessor し、EventProcessorHost に登録する必要があります。
Dispose(Boolean)	EventHub メッセージを処理するための非常にシンプルなホスト。 EventProcessorHost インスタンス間で EventHub パーティションを分散する処理を行います。 EventHub で各パーティションに対して Azure ブロック BLOB を作成し、これらの BLOB を使用してパーティションのリースを管理します。 すべての EventProcessorHost インスタンスは、次の 2 つのタスクを実行しています。1) リースの更新: ホストが現在所有しているリースを追跡し、リースの更新を継続的に続けます。 2) リースの取得: 各インスタンスは、すべてのリース BLOB を継続的にポーリングしてチェックし、システムがバランスのとれた状態にするために取得する必要があるリースがあるかどうかを確認します。 クライアント アプリケーションでは、プロセッサの実装を実装 IEventProcessor し、EventProcessorHost に登録する必要があります。
RegisterEventProcessorAsync<T>()	ファクトリを使用して、インターフェイスの IEventProcessor 実装をホストに非同期的に DefaultEventProcessorFactory<T> 登録します。 また、このメソッドはホストを起動し、パーティション分散プロセスへの参加を開始できるようにします。
RegisterEventProcessorAsync<T>(EventProcessorOptions)	これにより、 を IEventProcessor 使用して DefaultEventProcessorFactory<T>ホストに実装が登録されます。 これによりホストも開始され、パーティション分散プロセスへの参加が開始されます。
RegisterEventProcessorFactoryAsync(IEventProcessorFactory)	これにより、パーティションの IEventProcessorFactory 所有権を取得するときに の IEventProcessor インスタンスを作成するために使用されるホストに実装が登録されます。 これによりホストも開始され、パーティション分散プロセスへの参加が開始されます。
RegisterEventProcessorFactoryAsync(IEventProcessorFactory, EventProcessorOptions)	これにより、パーティションの IEventProcessorFactory 所有権を取得するときに の IEventProcessor インスタンスを作成するために使用されるホストに実装が登録されます。 これによりホストも開始され、パーティション分散プロセスへの参加が開始されます。
ResetAllConnections()	EventProcessorHost のこのインスタンスで使用されるすべての Event Hubs レシーバー接続をリセットします。
ResetConnection(String)	EventHub メッセージを処理するための非常にシンプルなホスト。 EventProcessorHost インスタンス間で EventHub パーティションを分散する処理を行います。 EventHub で各パーティションに対して Azure ブロック BLOB を作成し、これらの BLOB を使用してパーティションのリースを管理します。 すべての EventProcessorHost インスタンスは、次の 2 つのタスクを実行しています。1) リースの更新: ホストが現在所有しているリースを追跡し、リースの更新を継続的に続けます。 2) リースの取得: 各インスタンスは、すべてのリース BLOB を継続的にポーリングしてチェックし、システムがバランスのとれた状態にするために取得する必要があるリースがあるかどうかを確認します。 クライアント アプリケーションでは、プロセッサの実装を実装 IEventProcessor し、EventProcessorHost に登録する必要があります。
UnregisterEventProcessorAsync()	インスタンスを非同期的に EventProcessorHost シャットダウンします。 このメソッドは、現在保持されているすべてのパーティションのリースを維持し、現在のProcessEventsAsync(PartitionContext, IEnumerable<EventData>)実行が完了した後に オブジェクトをCloseAsync(PartitionContext, CloseReason)使用Shutdownして メソッドを呼び出すことで、各IEventProcessorインスタンスをクリーンにシャットダウンできるようにします。