EventProcessorHost Klasse

Definition

Namespace:

Microsoft.ServiceBus.Messaging

Assembly:

Microsoft.ServiceBus.Messaging.EventProcessorHost.dll

Paket:

Microsoft.Azure.ServiceBus.EventProcessorHost v5.0.1

Ein sehr einfacher Host zum Verarbeiten von EventHub-Nachrichten. Es kümmert sich um die Verteilung von EventHub-Partitionen auf EventProcessorHost-Instanzen. Es erstellt ein Azure-Blockblob für jede Partition in EventHub und verwendet diese Blobs zum Verwalten der Lease für eine Partition. Jeder EventProcessorHost-instance führt die folgenden zwei Aufgaben aus: 1) Lease erneuern: Es verfolgt die Leases, die sich derzeit im Besitz des Hosts befinden, und verlängert die Leases kontinuierlich. 2) Erwerben von Leases: Jeder instance fragt kontinuierlich alle Leaseblobs ab, um zu überprüfen, ob Leases vorhanden sind, die erworben werden sollten, damit das System in einen ausgeglichenen Zustand versetzt wird. Die Clientanwendung muss die Prozessorimplementierung bei EventProcessorHost implementieren IEventProcessor und registrieren.

public class EventProcessorHost : IDisposable

type EventProcessorHost = class
    interface IDisposable

Public Class EventProcessorHost
Implements IDisposable

Vererbung

Object

EventProcessorHost

Implementiert

IDisposable

Konstruktoren

EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>)	Erstellt eine neue instance von EventProcessorHost.
EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>, String, String)	Erstellt eine neue instance von EventProcessorHost.
EventProcessorHost(String, String, String, String)	Erstellt eine neue instance von EventProcessorHost.
EventProcessorHost(String, String, String, String, String)	Initialisiert eine neue Instanz der EventProcessorHost-Klasse.
EventProcessorHost(String, String, String, String, String, String, String)	Initialisiert eine neue Instanz der EventProcessorHost-Klasse.

Eigenschaften

HostName	Ruft den Hostnamen ab, der ein eindeutiger Name für die EventProcessorHost instance ist.
PartitionManagerOptions	Ruft die PartitionManagerOptions vom -Objekt verwendete instance ab oder legt sie EventProcessorHost fest.

Methoden

Dispose()	Ein sehr einfacher Host zum Verarbeiten von EventHub-Nachrichten. Es kümmert sich um die Verteilung von EventHub-Partitionen auf EventProcessorHost-Instanzen. Es erstellt ein Azure-Blockblob für jede Partition in EventHub und verwendet diese Blobs zum Verwalten der Lease für eine Partition. Jeder EventProcessorHost-instance führt die folgenden zwei Aufgaben aus: 1) Lease erneuern: Es verfolgt die Leases, die sich derzeit im Besitz des Hosts befinden, und verlängert die Leases kontinuierlich. 2) Erwerben von Leases: Jeder instance fragt kontinuierlich alle Leaseblobs ab, um zu überprüfen, ob Leases vorhanden sind, die erworben werden sollten, damit das System in einen ausgeglichenen Zustand versetzt wird. Die Clientanwendung muss die Prozessorimplementierung bei EventProcessorHost implementieren IEventProcessor und registrieren.
Dispose(Boolean)	Ein sehr einfacher Host zum Verarbeiten von EventHub-Nachrichten. Es kümmert sich um die Verteilung von EventHub-Partitionen auf EventProcessorHost-Instanzen. Es erstellt ein Azure-Blockblob für jede Partition in EventHub und verwendet diese Blobs zum Verwalten der Lease für eine Partition. Jeder EventProcessorHost-instance führt die folgenden zwei Aufgaben aus: 1) Lease erneuern: Es verfolgt die Leases, die sich derzeit im Besitz des Hosts befinden, und verlängert die Leases kontinuierlich. 2) Erwerben von Leases: Jeder instance fragt kontinuierlich alle Leaseblobs ab, um zu überprüfen, ob Leases vorhanden sind, die erworben werden sollten, damit das System in einen ausgeglichenen Zustand versetzt wird. Die Clientanwendung muss die Prozessorimplementierung bei EventProcessorHost implementieren IEventProcessor und registrieren.
RegisterEventProcessorAsync<T>()	Registriert die IEventProcessor Schnittstellenimplementierung mithilfe der DefaultEventProcessorFactory<T> Factory asynchron beim Host. Diese Methode startet auch den Host und ermöglicht es, am Partitionsverteilungsprozess teilzunehmen.
RegisterEventProcessorAsync<T>(EventProcessorOptions)	Dadurch wird die IEventProcessor Implementierung mit dem Host registriert DefaultEventProcessorFactory<T>. Dadurch wird auch der Host gestartet, und er beginnt, am Partitionsverteilungsprozess teilzunehmen.
RegisterEventProcessorFactoryAsync(IEventProcessorFactory)	Dadurch wird die Implementierung beim Host registriertIEventProcessorFactory, der verwendet wird, um eine instance von IEventProcessor zu erstellen, wenn er den Besitz einer Partition übernimmt. Dadurch wird auch der Host gestartet, und er beginnt, am Partitionsverteilungsprozess teilzunehmen.
RegisterEventProcessorFactoryAsync(IEventProcessorFactory, EventProcessorOptions)	Dadurch wird die Implementierung beim Host registriertIEventProcessorFactory, der verwendet wird, um eine instance von IEventProcessor zu erstellen, wenn er den Besitz einer Partition übernimmt. Dadurch wird auch der Host gestartet, und er beginnt, am Partitionsverteilungsprozess teilzunehmen.
ResetAllConnections()	Setzen Sie alle Event Hubs-Empfängerverbindungen zurück, die von dieser instance von EventProcessorHost verwendet werden.
ResetConnection(String)	Ein sehr einfacher Host zum Verarbeiten von EventHub-Nachrichten. Es kümmert sich um die Verteilung von EventHub-Partitionen auf EventProcessorHost-Instanzen. Es erstellt ein Azure-Blockblob für jede Partition in EventHub und verwendet diese Blobs zum Verwalten der Lease für eine Partition. Jeder EventProcessorHost-instance führt die folgenden zwei Aufgaben aus: 1) Lease erneuern: Es verfolgt die Leases, die sich derzeit im Besitz des Hosts befinden, und verlängert die Leases kontinuierlich. 2) Erwerben von Leases: Jeder instance fragt kontinuierlich alle Leaseblobs ab, um zu überprüfen, ob Leases vorhanden sind, die erworben werden sollten, damit das System in einen ausgeglichenen Zustand versetzt wird. Die Clientanwendung muss die Prozessorimplementierung bei EventProcessorHost implementieren IEventProcessor und registrieren.
UnregisterEventProcessorAsync()	Beendet die EventProcessorHost instance asynchron. Diese Methode verwaltet die Leases für alle derzeit gehaltenen Partitionen und ermöglicht es jedem IEventProcessor instance, die Methode nach Abschluss der CloseAsync(PartitionContext, CloseReason)ProcessEventsAsync(PartitionContext, IEnumerable<EventData>) aktuellen Ausführung mit einem Shutdown -Objekt sauber herunterzufahren.