EventHubConsumerGroup Klasse

Referenz

Definition

Namespace:: Microsoft.ServiceBus.Messaging

Assembly:: Microsoft.ServiceBus.dll

Paket:: WindowsAzure.ServiceBus v6.2.2

Wichtig

Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.

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: Object

ClientEntity
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

Gilt für: