Freigeben über


EventHubConsumerGroup Klasse

Definition

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

public sealed class EventHubConsumerGroup : Microsoft.ServiceBus.Messaging.ClientEntity
type EventHubConsumerGroup = class
    inherit ClientEntity
Public NotInheritable Class EventHubConsumerGroup
Inherits ClientEntity
Vererbung
EventHubConsumerGroup

Felder

DefaultGroupName

Der Name der Standardmäßigen ConsumerGroup, die beim Erstellen von EventHub vorab erstellt wird.

EndOfStream

Die Konstante, die das Ende eines Streams angibt. Dies kann als Offsetargument bei der Empfängererstellung verwendet werden, um mit dem Empfang des letzten Ereignisses anstelle eines bestimmten Zeitpunkts/Offsetwerts zu beginnen.

StartOfStream

Die Konstante, die den Anfang eines Datenstroms angibt. Dies kann als Offsetargument bei der Empfängererstellung verwendet werden.

Eigenschaften

EnableReceiverRuntimeMetric

Ruft einen Wert ab, der angibt, ob die Laufzeitmetrik eines Empfängers aktiviert ist, oder legt den Wert fest.

EventHubPath

Ruft den Event Hub-Pfad ab.

GroupName

Ruft den Namen der Consumergruppe ab.

IsClosed

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
PrefetchCount

Ruft die Anzahl der Ereignisse ab, die von einem Empfangsvorgang aktiv zwischengespeichert werden, oder legt diese fest. Standardmäßig wird dieser Wert von EventHubClientgeerbt. Der Standardwert ist 10,000.

PrefetchSizeInBytes

Ruft die maximale Gesamtgröße (in Bytes) ab, die von jedem Empfangsvorgang aktiv zwischengespeichert wird, oder legt diese fest. Die Größe der einzelnen Ereignisdaten wird durch die SerializedSizeInBytes -Eigenschaft bestimmt.

RetryPolicy

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
ThisLock

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)

Methoden

Abort()

Führt abbruchfunktionen für die Messagingentität aus.

(Geerbt von ClientEntity)
Close()

Sendet eine Bereinigungsnachricht an Service Bus, um den Abschluss der Verwendung einer Entität zu signalisieren.

(Geerbt von ClientEntity)
CloseAsync()

Sendet eine Bereinigungsnachricht asynchron an Service Bus, um den Abschluss der Verwendung einer Entität zu signalisieren.

(Geerbt von ClientEntity)
CreateReceiver(String, DateTime, Int64, ReceiverOptions)

Erstellt einen neuen Event Hubs-Empfänger in der angegebenen Partition, beginnend am angegebenen Datum und der angegebenen Uhrzeit. Sie können den erstellten Empfänger verwenden, um Ereignisse für eine Event Hubs-Partition zu empfangen, die durch angegeben wird partitionId.

CreateReceiver(String, DateTime, ReceiverOptions)

Erstellt einen neuen Event Hubs-Empfänger in der angegebenen Partition, beginnend am angegebenen Datum und der angegebenen Uhrzeit. Sie können den erstellten Empfänger verwenden, um Ereignisse für eine Event Hubs-Partition zu empfangen, die durch angegeben wird partitionId.

CreateReceiver(String, EventPosition, Nullable<Int64>, ReceiverOptions)

Erstellt einen neuen Event Hubs-Empfänger in der angegebenen Partition an der angegebenen Startposition. Sie können den erstellten Empfänger verwenden, um Ereignisse für eine Event Hubs-Partition zu empfangen, die durch angegeben wird partitionId.

CreateReceiver(String, Int64, ReceiverOptions)

Erstellt einen neuen Event Hubs-Empfänger in der angegebenen Partition und den angegebenen Epochenwert. Sie können den erstellten Empfänger verwenden, um Ereignisse für eine Event Hubs-Partition zu empfangen, die durch angegeben wird partitionId.

CreateReceiver(String, ReceiverOptions)

Erstellt einen neuen Event Hubs-Empfänger in der angegebenen Partition. Sie können den erstellten Empfänger verwenden, um Ereignisse für eine Event Hubs-Partition zu empfangen, die durch angegeben wird partitionId.

CreateReceiver(String, String, Boolean, Int64, ReceiverOptions)

Erstellt einen neuen Event Hubs-Empfänger in der angegebenen Partition am angegebenen Startoffset. Sie können den erstellten Empfänger verwenden, um Ereignisse für eine Event Hubs-Partition zu empfangen, die durch angegeben wird partitionId.

CreateReceiver(String, String, Boolean, ReceiverOptions)

Erstellt einen neuen Event Hubs-Empfänger in der angegebenen Partition am angegebenen Startoffset. Sie können den erstellten Empfänger verwenden, um Ereignisse für eine Event Hubs-Partition zu empfangen, die durch angegeben wird partitionId.

CreateReceiver(String, String, Int64, ReceiverOptions)

Erstellt einen neuen Event Hubs-Empfänger in der angegebenen Partition am angegebenen Startoffset.

CreateReceiver(String, String, ReceiverOptions)

Erstellt einen neuen Event Hubs-Empfänger in der angegebenen Partition am angegebenen Startoffset. Sie können den erstellten Empfänger verwenden, um Ereignisse für eine Event Hubs-Partition zu empfangen, die durch angegeben wird partitionId.

CreateReceiverAsync(String, DateTime, Int64, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, DateTime, Int64, ReceiverOptions).

CreateReceiverAsync(String, DateTime, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, DateTime, ReceiverOptions).

CreateReceiverAsync(String, EventPosition, Nullable<Int64>, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, EventPosition, Nullable<Int64>, ReceiverOptions).

CreateReceiverAsync(String, Int64, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, Int64, ReceiverOptions).

CreateReceiverAsync(String, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, ReceiverOptions).

CreateReceiverAsync(String, String, Boolean, Int64, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, String, Boolean, Int64, ReceiverOptions).

CreateReceiverAsync(String, String, Boolean, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, String, Boolean, ReceiverOptions).

CreateReceiverAsync(String, String, Int64, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, String, Int64, ReceiverOptions).

CreateReceiverAsync(String, String, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, ReceiverOptions).

Fault()

Nur zur internen Verwendung. Verhindern Sie das Erben von dieser Klasse.

(Geerbt von ClientEntity)
OnAbort()

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
OnBeginClose(TimeSpan, AsyncCallback, Object)

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
OnBeginOpen(TimeSpan, AsyncCallback, Object)

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
OnClose(TimeSpan)

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
OnClosed()

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
OnEndClose(IAsyncResult)

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
OnEndOpen(IAsyncResult)

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
OnFaulted()

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
OnOpen(TimeSpan)

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
OnOpened()

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
RegisterProcessor<T>(Lease, ICheckpointManager)

Registriert eine Implementierung von, um mit der IEventProcessor Nutzung von Ereignissen aus Event Hubs für den angegebenen PartitionId ab Offsetzu beginnen. Verwenden Sie diese Überladung, um einen Ereignisprozessor zu erstellen, der den Nachrichtenoffset mithilfe einer benutzerdefinierten Implementierung von ICheckpointManagerprüft.

RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions)

Registriert eine Implementierung von, um mit der IEventProcessor Nutzung von Ereignissen aus Event Hubs für den angegebenen PartitionId ab Offsetzu beginnen. Verwenden Sie diese Überladung, um einen Ereignisprozessor zu erstellen, der den Nachrichtenoffset mithilfe einer benutzerdefinierten Implementierung von ICheckpointManagerprüft.

RegisterProcessorAsync<T>(Lease, ICheckpointManager)

Asynchrone Version von RegisterProcessor<T>(Lease, ICheckpointManager).

RegisterProcessorAsync<T>(Lease, ICheckpointManager, EventProcessorOptions)

Asynchrone Version von RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions).

RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory)

Registriert das -Objekt, das IEventProcessorFactory zum Erstellen einer instance von verwendet wird, um mit der Nutzung von IEventProcessor Ereignissen für die von PartitionIdangegebene Partition zu beginnen, beginnend mit Offset. Verwenden Sie diese Überladung, um einen Ereignisprozessor zu erstellen, der den Nachrichtenoffset mithilfe einer benutzerdefinierten Implementierung von ICheckpointManagerprüft.

RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions)

Registriert das -Objekt, das IEventProcessorFactory zum Erstellen einer instance von verwendet wird, um mit der Nutzung von IEventProcessor Ereignissen für die von PartitionIdangegebene Partition zu beginnen, beginnend mit Offset. Verwenden Sie diese Überladung, um einen Ereignisprozessor zu erstellen, der den Nachrichtenoffset mithilfe einer benutzerdefinierten Implementierung von ICheckpointManagerprüft.

RegisterProcessorFactoryAsync(Lease, ICheckpointManager, IEventProcessorFactory)

Asynchrone Version von RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory).

RegisterProcessorFactoryAsync(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions)

Asynchrone Version von RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions).

ThrowIfClosed()

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
ThrowIfDisposed()

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
ThrowIfDisposedOrImmutable()

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
ThrowIfDisposedOrNotOpen()

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
ThrowIfFaulted()

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

(Geerbt von ClientEntity)
UnregisterProcessor(Lease, CloseReason)

Hebt die IEventProcessor Registrierung für die von angegebene Partition auf PartitionId. Dies führt dazu, CloseAsync(PartitionContext, CloseReason) dass auf dem zugrunde liegenden Ereignisprozessor aufgerufen wird.

UnregisterProcessorAsync(Lease, CloseReason)

Asynchrone Version von UnregisterProcessor(Lease, CloseReason).

Ereignisse

EventProcessorLifeCycleManagerFaulted

Stellt die Consumergruppe in einem Event Hub dar. Diese Klasse erstellt Empfänger für eine bestimmte Consumergruppe innerhalb eines Event Hubs. Dies kann die Standardconsumergruppe oder eine andere vom Benutzer erstellte Consumergruppe sein.

Gilt für: