Partager via


EventHubConsumerGroup Classe

Définition

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

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

Champs

DefaultGroupName

Nom du ConsumerGroup par défaut qui est précréé lors de la création d’EventHub.

EndOfStream

Constante qui indique la fin d’un flux. Il peut être utilisé comme argument de décalage dans la création du récepteur pour commencer à recevoir à partir de l’événement le plus récent, au lieu d’un point spécifique dans le temps/d’une valeur de décalage.

StartOfStream

Constante qui indique le début d’un flux. Il peut être utilisé comme argument de décalage dans la création du récepteur.

Propriétés

EnableReceiverRuntimeMetric

Obtient ou définit une valeur indiquant si la métrique d’exécution d’un récepteur est activée.

EventHubPath

Obtient le chemin du hub d’événements.

GroupName

Obtient le nom du groupe de consommateurs.

IsClosed

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
PrefetchCount

Obtient ou définit le nombre d’événements que toute opération de réception met en cache activement. Par défaut, cette valeur est héritée de EventHubClient. La valeur par défaut est 10 000.

PrefetchSizeInBytes

Obtient ou définit la taille maximale (en octets) totale que toute opération de réception mettra activement en cache. La taille de chaque données d’événement est déterminée par la SerializedSizeInBytes propriété .

RetryPolicy

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
ThisLock

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)

Méthodes

Abort()

Exécute la fonctionnalité d’abandon sur l’entité de messagerie.

(Hérité de ClientEntity)
Close()

Envoie un message de nettoyage à Service Bus pour signaler la fin de l’utilisation d’une entité.

(Hérité de ClientEntity)
CloseAsync()

Envoie un message de nettoyage de façon asynchrone à Service Bus pour signaler la fin de l’utilisation d’une entité.

(Hérité de ClientEntity)
CreateReceiver(String, DateTime, Int64, ReceiverOptions)

Crée un récepteur Event Hubs dans la partition spécifiée, en commençant à la date et l’heure spécifiées. Vous pouvez utiliser le récepteur créé pour recevoir des événements pour une partition Event Hubs, spécifiée par partitionId.

CreateReceiver(String, DateTime, ReceiverOptions)

Crée un récepteur Event Hubs dans la partition spécifiée, en commençant à la date et l’heure spécifiées. Vous pouvez utiliser le récepteur créé pour recevoir des événements pour une partition Event Hubs, spécifiée par partitionId.

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

Crée un récepteur Event Hubs dans la partition spécifiée, à la position de départ spécifiée. Vous pouvez utiliser le récepteur créé pour recevoir des événements pour une partition Event Hubs, spécifiée par partitionId.

CreateReceiver(String, Int64, ReceiverOptions)

Crée un récepteur Event Hubs dans la partition spécifiée et la valeur d’époque spécifiée. Vous pouvez utiliser le récepteur créé pour recevoir des événements pour une partition Event Hubs, spécifiée par partitionId.

CreateReceiver(String, ReceiverOptions)

Crée un récepteur Event Hubs dans la partition spécifiée. Vous pouvez utiliser le récepteur créé pour recevoir des événements pour une partition Event Hubs, spécifiée par partitionId.

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

Crée un récepteur Event Hubs dans la partition spécifiée, au décalage de départ spécifié. Vous pouvez utiliser le récepteur créé pour recevoir des événements pour une partition Event Hubs, spécifiée par partitionId.

CreateReceiver(String, String, Boolean, ReceiverOptions)

Crée un récepteur Event Hubs dans la partition spécifiée, au décalage de départ spécifié. Vous pouvez utiliser le récepteur créé pour recevoir des événements pour une partition Event Hubs, spécifiée par partitionId.

CreateReceiver(String, String, Int64, ReceiverOptions)

Crée un récepteur Event Hubs dans la partition spécifiée, au décalage de départ spécifié.

CreateReceiver(String, String, ReceiverOptions)

Crée un récepteur Event Hubs dans la partition spécifiée, au décalage de départ spécifié. Vous pouvez utiliser le récepteur créé pour recevoir des événements pour une partition Event Hubs, spécifiée par partitionId.

CreateReceiverAsync(String, DateTime, Int64, ReceiverOptions)

Version asynchrone de CreateReceiver(String, DateTime, Int64, ReceiverOptions).

CreateReceiverAsync(String, DateTime, ReceiverOptions)

Version asynchrone de CreateReceiver(String, DateTime, ReceiverOptions).

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

Version asynchrone de CreateReceiver(String, EventPosition, Nullable<Int64>, ReceiverOptions).

CreateReceiverAsync(String, Int64, ReceiverOptions)

Version asynchrone de CreateReceiver(String, Int64, ReceiverOptions).

CreateReceiverAsync(String, ReceiverOptions)

Version asynchrone de CreateReceiver(String, ReceiverOptions).

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

Version asynchrone de CreateReceiver(String, String, Boolean, Int64, ReceiverOptions).

CreateReceiverAsync(String, String, Boolean, ReceiverOptions)

Version asynchrone de CreateReceiver(String, String, Boolean, ReceiverOptions).

CreateReceiverAsync(String, String, Int64, ReceiverOptions)

Version asynchrone de CreateReceiver(String, String, Int64, ReceiverOptions).

CreateReceiverAsync(String, String, ReceiverOptions)

Version asynchrone de CreateReceiver(String, ReceiverOptions).

Fault()

À usage interne uniquement. N’héritez pas de cette classe.

(Hérité de ClientEntity)
OnAbort()

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
OnBeginClose(TimeSpan, AsyncCallback, Object)

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
OnBeginOpen(TimeSpan, AsyncCallback, Object)

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
OnClose(TimeSpan)

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
OnClosed()

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
OnEndClose(IAsyncResult)

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
OnEndOpen(IAsyncResult)

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
OnFaulted()

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
OnOpen(TimeSpan)

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
OnOpened()

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
RegisterProcessor<T>(Lease, ICheckpointManager)

Inscrit une implémentation de afin de IEventProcessor commencer à consommer des événements à partir d’Event Hubs pour le spécifié PartitionId à partir de Offset. Utilisez cette surcharge pour créer un processeur d’événements qui contrôle le décalage de message à l’aide d’une implémentation personnalisée de ICheckpointManager.

RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions)

Inscrit une implémentation de afin de IEventProcessor commencer à consommer des événements à partir d’Event Hubs pour le spécifié PartitionId à partir de Offset. Utilisez cette surcharge pour créer un processeur d’événements qui contrôle le décalage de message à l’aide d’une implémentation personnalisée de ICheckpointManager.

RegisterProcessorAsync<T>(Lease, ICheckpointManager)

Version asynchrone de RegisterProcessor<T>(Lease, ICheckpointManager).

RegisterProcessorAsync<T>(Lease, ICheckpointManager, EventProcessorOptions)

Version asynchrone de RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions).

RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory)

Inscrit l’objet IEventProcessorFactory utilisé pour créer un instance de afin de IEventProcessor commencer à consommer des événements pour la partition spécifiée par PartitionId, à partir de Offset. Utilisez cette surcharge pour créer un processeur d’événements qui contrôle le décalage de message à l’aide d’une implémentation personnalisée de ICheckpointManager.

RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions)

Inscrit l’objet IEventProcessorFactory utilisé pour créer un instance de afin de IEventProcessor commencer à consommer des événements pour la partition spécifiée par PartitionId, à partir de Offset. Utilisez cette surcharge pour créer un processeur d’événements qui contrôle le décalage de message à l’aide d’une implémentation personnalisée de ICheckpointManager.

RegisterProcessorFactoryAsync(Lease, ICheckpointManager, IEventProcessorFactory)

Version asynchrone de RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory).

RegisterProcessorFactoryAsync(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions)

Version asynchrone de RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions).

ThrowIfClosed()

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
ThrowIfDisposed()

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
ThrowIfDisposedOrImmutable()

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
ThrowIfDisposedOrNotOpen()

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
ThrowIfFaulted()

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

(Hérité de ClientEntity)
UnregisterProcessor(Lease, CloseReason)

Annule l’inscription IEventProcessor pour la partition spécifiée par PartitionId. Cela entraîne CloseAsync(PartitionContext, CloseReason) l’appel du processeur d’événements sous-jacent.

UnregisterProcessorAsync(Lease, CloseReason)

Version asynchrone de UnregisterProcessor(Lease, CloseReason).

Événements

EventProcessorLifeCycleManagerFaulted

Représente le groupe de consommateurs au sein d’un Event Hub. Cette classe crée des récepteurs pour un groupe de consommateurs spécifique au sein d’un Event Hub. Il peut s’agir du groupe de consommateurs par défaut ou d’un autre groupe de consommateurs créé par l’utilisateur.

S’applique à