EventHubConsumerGroup Clase
Definición
Importante
Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.
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
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 |
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 |
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 |
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 |
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 |
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 |
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 |
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 |
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
Azure SDK for .NET