Compartir a través de


EventHubConsumerGroup Clase

Definición

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

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

Campos

DefaultGroupName

Nombre del ConsumerGroup predeterminado que se crea previamente al crear EventHub.

EndOfStream

Constante que indica el final de una secuencia. Esto se puede usar como argumento de desplazamiento en la creación del receptor para empezar a recibir desde el evento más reciente, en lugar de un valor específico en el tiempo o desplazamiento.

StartOfStream

Constante que indica el inicio de una secuencia. Esto se puede usar como argumento offset en la creación del receptor.

Propiedades

EnableReceiverRuntimeMetric

Obtiene o establece un valor que indica si la métrica en tiempo de ejecución de un receptor está habilitada.

EventHubPath

Obtiene la ruta de acceso del centro de eventos.

GroupName

Obtiene el nombre del grupo de consumidores.

IsClosed

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
PrefetchCount

Obtiene o establece el número de eventos que cualquier operación de recepción almacenará en caché de forma activa. De forma predeterminada, este valor se hereda de EventHubClient. El valor predeterminado es 10,000.

PrefetchSizeInBytes

Obtiene o establece el tamaño máximo (en bytes) en total que cualquier operación de recepción almacenará en caché activamente. El tamaño de cada dato de evento viene determinado por la SerializedSizeInBytes propiedad .

RetryPolicy

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
ThisLock

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)

Métodos

Abort()

Realiza la funcionalidad de anulación en la entidad de mensajería.

(Heredado de ClientEntity)
Close()

Envía un mensaje de limpieza a Service Bus para indicar la finalización del uso de una entidad.

(Heredado de ClientEntity)
CloseAsync()

Envía un mensaje de limpieza de forma asincrónica a Service Bus para indicar la finalización del uso de una entidad.

(Heredado de ClientEntity)
CreateReceiver(String, DateTime, Int64, ReceiverOptions)

Crea un nuevo receptor de Event Hubs en la partición especificada, empezando por la fecha y hora especificadas. Puede usar el receptor creado para recibir eventos de una partición de Event Hubs, especificada por partitionId.

CreateReceiver(String, DateTime, ReceiverOptions)

Crea un nuevo receptor de Event Hubs en la partición especificada, empezando por la fecha y hora especificadas. Puede usar el receptor creado para recibir eventos de una partición de Event Hubs, especificada por partitionId.

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

Crea un nuevo receptor de Event Hubs en la partición especificada, en la posición inicial especificada. Puede usar el receptor creado para recibir eventos de una partición de Event Hubs, especificada por partitionId.

CreateReceiver(String, Int64, ReceiverOptions)

Crea un nuevo receptor de Event Hubs en la partición especificada y el valor de época especificado. Puede usar el receptor creado para recibir eventos de una partición de Event Hubs, especificada por partitionId.

CreateReceiver(String, ReceiverOptions)

Crea un nuevo receptor de Event Hubs en la partición especificada. Puede usar el receptor creado para recibir eventos de una partición de Event Hubs, especificada por partitionId.

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

Crea un nuevo receptor de Event Hubs en la partición especificada, en el desplazamiento inicial especificado. Puede usar el receptor creado para recibir eventos de una partición de Event Hubs, especificada por partitionId.

CreateReceiver(String, String, Boolean, ReceiverOptions)

Crea un nuevo receptor de Event Hubs en la partición especificada, en el desplazamiento inicial especificado. Puede usar el receptor creado para recibir eventos de una partición de Event Hubs, especificada por partitionId.

CreateReceiver(String, String, Int64, ReceiverOptions)

Crea un nuevo receptor de Event Hubs en la partición especificada, en el desplazamiento inicial especificado.

CreateReceiver(String, String, ReceiverOptions)

Crea un nuevo receptor de Event Hubs en la partición especificada, en el desplazamiento inicial especificado. Puede usar el receptor creado para recibir eventos de una partición de Event Hubs, especificada por partitionId.

CreateReceiverAsync(String, DateTime, Int64, ReceiverOptions)

Versión asincrónica de CreateReceiver(String, DateTime, Int64, ReceiverOptions).

CreateReceiverAsync(String, DateTime, ReceiverOptions)

Versión asincrónica de CreateReceiver(String, DateTime, ReceiverOptions).

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

Versión asincrónica de CreateReceiver(String, EventPosition, Nullable<Int64>, ReceiverOptions).

CreateReceiverAsync(String, Int64, ReceiverOptions)

Versión asincrónica de CreateReceiver(String, Int64, ReceiverOptions).

CreateReceiverAsync(String, ReceiverOptions)

Versión asincrónica de CreateReceiver(String, ReceiverOptions).

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

Versión asincrónica de CreateReceiver(String, String, Boolean, Int64, ReceiverOptions).

CreateReceiverAsync(String, String, Boolean, ReceiverOptions)

Versión asincrónica de CreateReceiver(String, String, Boolean, ReceiverOptions).

CreateReceiverAsync(String, String, Int64, ReceiverOptions)

Versión asincrónica de CreateReceiver(String, String, Int64, ReceiverOptions).

CreateReceiverAsync(String, String, ReceiverOptions)

Versión asincrónica de CreateReceiver(String, ReceiverOptions).

Fault()

Solo para uso interno. No herede de esta clase.

(Heredado de ClientEntity)
OnAbort()

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
OnBeginClose(TimeSpan, AsyncCallback, Object)

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
OnBeginOpen(TimeSpan, AsyncCallback, Object)

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
OnClose(TimeSpan)

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
OnClosed()

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
OnEndClose(IAsyncResult)

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
OnEndOpen(IAsyncResult)

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
OnFaulted()

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
OnOpen(TimeSpan)

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
OnOpened()

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
RegisterProcessor<T>(Lease, ICheckpointManager)

Registra una implementación de IEventProcessor para empezar a consumir eventos de Event Hubs para el especificado PartitionId a partir de Offset. Use esta sobrecarga para crear un procesador de eventos que controle el desplazamiento del mensaje mediante una implementación personalizada de ICheckpointManager.

RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions)

Registra una implementación de IEventProcessor para empezar a consumir eventos de Event Hubs para el especificado PartitionId a partir de Offset. Use esta sobrecarga para crear un procesador de eventos que controle el desplazamiento del mensaje mediante una implementación personalizada de ICheckpointManager.

RegisterProcessorAsync<T>(Lease, ICheckpointManager)

Versión asincrónica de RegisterProcessor<T>(Lease, ICheckpointManager).

RegisterProcessorAsync<T>(Lease, ICheckpointManager, EventProcessorOptions)

Versión asincrónica de RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions).

RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory)

Registra el IEventProcessorFactory objeto utilizado para crear una instancia de IEventProcessor para empezar a consumir eventos para la partición especificada por PartitionId, a partir de Offset. Use esta sobrecarga para crear un procesador de eventos que controle el desplazamiento del mensaje mediante una implementación personalizada de ICheckpointManager.

RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions)

Registra el IEventProcessorFactory objeto utilizado para crear una instancia de IEventProcessor para empezar a consumir eventos para la partición especificada por PartitionId, a partir de Offset. Use esta sobrecarga para crear un procesador de eventos que controle el desplazamiento del mensaje mediante una implementación personalizada de ICheckpointManager.

RegisterProcessorFactoryAsync(Lease, ICheckpointManager, IEventProcessorFactory)

Versión asincrónica de RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory).

RegisterProcessorFactoryAsync(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions)

Versión asincrónica de RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions).

ThrowIfClosed()

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
ThrowIfDisposed()

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
ThrowIfDisposedOrImmutable()

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
ThrowIfDisposedOrNotOpen()

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
ThrowIfFaulted()

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

(Heredado de ClientEntity)
UnregisterProcessor(Lease, CloseReason)

Anula el IEventProcessor registro de la partición especificada por PartitionId. Esto da lugar a CloseAsync(PartitionContext, CloseReason) una llamada en el procesador de eventos subyacente.

UnregisterProcessorAsync(Lease, CloseReason)

Versión asincrónica de UnregisterProcessor(Lease, CloseReason).

Eventos

EventProcessorLifeCycleManagerFaulted

Representa el grupo de consumidores dentro de un centro de eventos. Esta clase crea receptores para un grupo de consumidores específico dentro de un centro de eventos. Puede ser el grupo de consumidores predeterminado u otro grupo de consumidores creado por el usuario.

Se aplica a