EventHubConsumerGroup Classe

Definição

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

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

Campos

DefaultGroupName

O nome do ConsumerGroup padrão que é pré-criado ao criar o EventHub.

EndOfStream

A constante que indica o fim de um fluxo. Isso pode ser usado como um argumento de deslocamento na criação do receptor para começar a receber do evento mais recente, em vez de um ponto específico no valor de tempo/deslocamento.

StartOfStream

A constante que indica o início de um fluxo. Isso pode ser usado como um argumento de deslocamento na criação do receptor.

Propriedades

EnableReceiverRuntimeMetric

Obtém ou define um valor que indica se a métrica de runtime de um receptor está habilitada.

EventHubPath

Obtém o caminho do hub de eventos.

GroupName

Obtém o nome do grupo de consumidores.

IsClosed

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
PrefetchCount

Obtém ou define o número de eventos que qualquer operação de recebimento armazenará em cache ativamente. Por padrão, esse valor é herdado de EventHubClient. O valor padrão é 10.000.

PrefetchSizeInBytes

Obtém ou define o tamanho máximo (em bytes) no total que qualquer operação de recebimento armazenará em cache ativamente. O tamanho de cada dados de evento é determinado pela SerializedSizeInBytes propriedade .

RetryPolicy

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
ThisLock

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)

Métodos

Abort()

Executa a funcionalidade de anulação na entidade de mensagens.

(Herdado de ClientEntity)
Close()

Envia uma mensagem de limpeza ao Barramento de Serviço para sinalizar a conclusão do uso de uma entidade.

(Herdado de ClientEntity)
CloseAsync()

Envia uma mensagem de limpeza de forma assíncrona ao Barramento de Serviço para sinalizar a conclusão do uso de uma entidade.

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

Cria um novo receptor dos Hubs de Eventos na partição especificada, começando na data e hora especificadas. Você pode usar o receptor criado para receber eventos para uma partição de Hubs de Eventos, especificada por partitionId.

CreateReceiver(String, DateTime, ReceiverOptions)

Cria um novo receptor dos Hubs de Eventos na partição especificada, começando na data e hora especificadas. Você pode usar o receptor criado para receber eventos para uma partição de Hubs de Eventos, especificada por partitionId.

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

Cria um novo receptor dos Hubs de Eventos na partição especificada, na posição inicial especificada. Você pode usar o receptor criado para receber eventos para uma partição de Hubs de Eventos, especificada por partitionId.

CreateReceiver(String, Int64, ReceiverOptions)

Cria um novo receptor dos Hubs de Eventos na partição especificada e o valor de época especificado. Você pode usar o receptor criado para receber eventos para uma partição de Hubs de Eventos, especificada por partitionId.

CreateReceiver(String, ReceiverOptions)

Cria um novo receptor dos Hubs de Eventos na partição especificada. Você pode usar o receptor criado para receber eventos para uma partição de Hubs de Eventos, especificada por partitionId.

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

Cria um novo receptor dos Hubs de Eventos na partição especificada, no deslocamento inicial especificado. Você pode usar o receptor criado para receber eventos para uma partição de Hubs de Eventos, especificada por partitionId.

CreateReceiver(String, String, Boolean, ReceiverOptions)

Cria um novo receptor dos Hubs de Eventos na partição especificada, no deslocamento inicial especificado. Você pode usar o receptor criado para receber eventos para uma partição de Hubs de Eventos, especificada por partitionId.

CreateReceiver(String, String, Int64, ReceiverOptions)

Cria um novo receptor dos Hubs de Eventos na partição especificada, no deslocamento inicial especificado.

CreateReceiver(String, String, ReceiverOptions)

Cria um novo receptor dos Hubs de Eventos na partição especificada, no deslocamento inicial especificado. Você pode usar o receptor criado para receber eventos para uma partição de Hubs de Eventos, especificada por partitionId.

CreateReceiverAsync(String, DateTime, Int64, ReceiverOptions)

Versão assíncrona de CreateReceiver(String, DateTime, Int64, ReceiverOptions).

CreateReceiverAsync(String, DateTime, ReceiverOptions)

Versão assíncrona de CreateReceiver(String, DateTime, ReceiverOptions).

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

Versão assíncrona de CreateReceiver(String, EventPosition, Nullable<Int64>, ReceiverOptions).

CreateReceiverAsync(String, Int64, ReceiverOptions)

Versão assíncrona de CreateReceiver(String, Int64, ReceiverOptions).

CreateReceiverAsync(String, ReceiverOptions)

Versão assíncrona de CreateReceiver(String, ReceiverOptions).

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

Versão assíncrona de CreateReceiver(String, String, Boolean, Int64, ReceiverOptions).

CreateReceiverAsync(String, String, Boolean, ReceiverOptions)

Versão assíncrona de CreateReceiver(String, String, Boolean, ReceiverOptions).

CreateReceiverAsync(String, String, Int64, ReceiverOptions)

Versão assíncrona de CreateReceiver(String, String, Int64, ReceiverOptions).

CreateReceiverAsync(String, String, ReceiverOptions)

Versão assíncrona de CreateReceiver(String, ReceiverOptions).

Fault()

Apenas para uso interno. Não herde dessa classe.

(Herdado de ClientEntity)
OnAbort()

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

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

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

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

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
OnClose(TimeSpan)

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
OnClosed()

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
OnEndClose(IAsyncResult)

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
OnEndOpen(IAsyncResult)

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
OnFaulted()

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
OnOpen(TimeSpan)

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
OnOpened()

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

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

Registra uma implementação de IEventProcessor para começar a consumir eventos dos Hubs de Eventos para o especificado PartitionId a partir de Offset. Use essa sobrecarga para criar um processador de eventos que verifica o deslocamento de mensagem usando uma implementação personalizada do ICheckpointManager.

RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions)

Registra uma implementação de IEventProcessor para começar a consumir eventos dos Hubs de Eventos para o especificado PartitionId a partir de Offset. Use essa sobrecarga para criar um processador de eventos que verifica o deslocamento de mensagem usando uma implementação personalizada do ICheckpointManager.

RegisterProcessorAsync<T>(Lease, ICheckpointManager)

Versão assíncrona de RegisterProcessor<T>(Lease, ICheckpointManager).

RegisterProcessorAsync<T>(Lease, ICheckpointManager, EventProcessorOptions)

Versão assíncrona de RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions).

RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory)

Registra o IEventProcessorFactory objeto usado para criar uma instância do IEventProcessor para começar a consumir eventos para a partição especificada por , começando por PartitionIdOffset. Use essa sobrecarga para criar um processador de eventos que verifica o deslocamento de mensagem usando uma implementação personalizada do ICheckpointManager.

RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions)

Registra o IEventProcessorFactory objeto usado para criar uma instância do IEventProcessor para começar a consumir eventos para a partição especificada por , começando por PartitionIdOffset. Use essa sobrecarga para criar um processador de eventos que verifica o deslocamento de mensagem usando uma implementação personalizada do ICheckpointManager.

RegisterProcessorFactoryAsync(Lease, ICheckpointManager, IEventProcessorFactory)

Versão assíncrona de RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory).

RegisterProcessorFactoryAsync(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions)

Versão assíncrona de RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions).

ThrowIfClosed()

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
ThrowIfDisposed()

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
ThrowIfDisposedOrImmutable()

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
ThrowIfDisposedOrNotOpen()

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
ThrowIfFaulted()

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

(Herdado de ClientEntity)
UnregisterProcessor(Lease, CloseReason)

Cancela o IEventProcessor registro da partição especificada por PartitionId. Isso resulta em CloseAsync(PartitionContext, CloseReason) ser chamado no processador de eventos subjacente.

UnregisterProcessorAsync(Lease, CloseReason)

Versão assíncrona de UnregisterProcessor(Lease, CloseReason).

Eventos

EventProcessorLifeCycleManagerFaulted

Representa o grupo de consumidores em um Hub de Eventos. Essa classe cria receptores para um grupo de consumidores específico em um Hub de Eventos. Esse pode ser o grupo de consumidores padrão ou outro grupo de consumidores criado pelo usuário.

Aplica-se a