次の方法で共有

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インスタンスをクリーンにシャットダウンできるようにします。

適用対象