EventHubConsumerGroup.CreateReceiverAsync Método
Definição
Importante
Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.
Sobrecargas
CreateReceiverAsync(String, String, Boolean, Int64, ReceiverOptions)
Versão assíncrona de CreateReceiver(String, String, Boolean, Int64, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, string startingOffset, bool offsetInclusive, long epoch, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * string * bool * int64 * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, startingOffset As String, offsetInclusive As Boolean, epoch As Long, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parâmetros
- partitionId
- String
A ID da partição.
- startingOffset
- String
O deslocamento inicial no qual começar a receber mensagens.
- offsetInclusive
- Boolean
Um valor booliano que indica se startingOffset é tratado como um deslocamento inclusivo, o que significa que o primeiro evento retornado é o evento que contém o deslocamento inicial. Normalmente, o primeiro evento retornado é o evento após o deslocamento inicial.
- epoch
- Int64
O valor da época. O serviço usa esse valor para impor a propriedade de partição/concessão.
- receiverOptions
- ReceiverOptions
Opções para um receptor do hub de eventos.
Retornos
Retorna Task<TResult>.
Aplica-se a
CreateReceiverAsync(String, String, Int64, ReceiverOptions)
Versão assíncrona de CreateReceiver(String, String, Int64, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, string startingOffset, long epoch, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * string * int64 * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, startingOffset As String, epoch As Long, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parâmetros
- partitionId
- String
A ID da partição.
- startingOffset
- String
O deslocamento inicial no qual começar a receber mensagens. Para especificar o início do fluxo, consulte StartOfStream.
- epoch
- Int64
O valor da época. O serviço usa esse valor para impor a propriedade de partição/concessão.
- receiverOptions
- ReceiverOptions
Opções para um receptor do hub de eventos.
Retornos
Retorna Task<TResult>.
Aplica-se a
CreateReceiverAsync(String, String, Boolean, ReceiverOptions)
Versão assíncrona de CreateReceiver(String, String, Boolean, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, string startingOffset, bool offsetInclusive, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * string * bool * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, startingOffset As String, offsetInclusive As Boolean, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parâmetros
- partitionId
- String
A ID da partição.
- startingOffset
- String
O deslocamento inicial no qual começar a receber mensagens.
- offsetInclusive
- Boolean
Um valor booliano que indica se startingOffset é tratado como um deslocamento inclusivo, o que significa que o primeiro evento retornado é o evento que contém o deslocamento inicial. Normalmente, o primeiro evento retornado é o evento após o deslocamento inicial.
- receiverOptions
- ReceiverOptions
Opções para um receptor do hub de eventos.
Retornos
Retorna Task<TResult>.
Aplica-se a
CreateReceiverAsync(String, DateTime, Int64, ReceiverOptions)
Versão assíncrona de CreateReceiver(String, DateTime, Int64, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, DateTime startingDateTimeUtc, long epoch, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * DateTime * int64 * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, startingDateTimeUtc As DateTime, epoch As Long, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parâmetros
- partitionId
- String
A ID da partição.
- startingDateTimeUtc
- DateTime
A hora UTC inicial para receber mensagens.
- epoch
- Int64
O valor da época. O serviço usa esse valor para impor a propriedade de partição/concessão.
- receiverOptions
- ReceiverOptions
Opções para um receptor do hub de eventos.
Retornos
Retorna Task<TResult>.
Comentários
O serviço usa isso startingDateTimeUtc apenas como uma aproximação ao determinar o próximo evento a ser entregue.
Tenha em mente que pode haver distorção de relógio entre a hora do cliente e a hora do serviço, portanto, o aplicativo do usuário deve ser projetado para lidar com a duplicação na entrega de eventos.
Aplica-se a
CreateReceiverAsync(String, DateTime, ReceiverOptions)
Versão assíncrona de CreateReceiver(String, DateTime, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, DateTime startingDateTimeUtc, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * DateTime * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, startingDateTimeUtc As DateTime, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parâmetros
- partitionId
- String
A ID da partição.
- startingDateTimeUtc
- DateTime
A hora UTC inicial para receber mensagens.
- receiverOptions
- ReceiverOptions
Opções para um receptor do hub de eventos.
Retornos
Retorna Task<TResult>.
Comentários
O serviço só usa isso startingDateTimeUtc como uma aproximação ao determinar o próximo evento a ser entregue.
Tenha em mente que pode haver distorção de relógio entre a hora do cliente e a hora do serviço, portanto, o aplicativo do usuário deve ser projetado para lidar com a duplicação na entrega de eventos.
Aplica-se a
CreateReceiverAsync(String, String, ReceiverOptions)
Versão assíncrona de CreateReceiver(String, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, string startingOffset, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * string * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, startingOffset As String, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parâmetros
- partitionId
- String
A ID da partição.
- startingOffset
- String
O deslocamento inicial no qual começar a receber mensagens.
- receiverOptions
- ReceiverOptions
Opções para um receptor do hub de eventos.
Retornos
Retorna Task<TResult>.
Aplica-se a
CreateReceiverAsync(String, Int64, ReceiverOptions)
Versão assíncrona de CreateReceiver(String, Int64, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, long epoch, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * int64 * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, epoch As Long, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parâmetros
- partitionId
- String
A ID da partição.
- epoch
- Int64
O valor da época. O serviço usa esse valor para impor a propriedade de partição/concessão.
- receiverOptions
- ReceiverOptions
Opções para um receptor do hub de eventos.
Retornos
Retorna Task<TResult>.
Comentários
Se o EventHubConsumerGroup tiver o ponto de verificação habilitado, o receptor receberá a próxima mensagem do deslocamento do ponto de verificação. Se o ponto de verificação estiver desabilitado, o receptor receberá a mensagem desde o início do fluxo de eventos, conforme determinado pela política de retenção de mensagens do Hub de Eventos.
Aplica-se a
CreateReceiverAsync(String, ReceiverOptions)
Versão assíncrona de CreateReceiver(String, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parâmetros
- partitionId
- String
A ID da partição.
- receiverOptions
- ReceiverOptions
Opções para um receptor do hub de eventos.
Retornos
Retorna Task<TResult>.
Comentários
Se o tiver o EventHubConsumerGroup ponto de verificação habilitado, essa sobrecarga sempre gerará InvalidOperationException porque o ConsumerGroup habilitado para ponto de verificação requer que a época funcione (use a sobrecarga que fornece época como argumento de entrada). Se o ponto de verificação estiver desabilitado, o receptor receberá a mensagem desde o início do fluxo de eventos, conforme determinado pela política de retenção de mensagens do Hub de Eventos.
Aplica-se a
CreateReceiverAsync(String, EventPosition, Nullable<Int64>, ReceiverOptions)
Versão assíncrona de CreateReceiver(String, EventPosition, Nullable<Int64>, ReceiverOptions).
public System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver> CreateReceiverAsync (string partitionId, Microsoft.ServiceBus.Messaging.EventPosition position, long? epoch = default, Microsoft.ServiceBus.Messaging.ReceiverOptions receiverOptions = default);member this.CreateReceiverAsync : string * Microsoft.ServiceBus.Messaging.EventPosition * Nullable<int64> * Microsoft.ServiceBus.Messaging.ReceiverOptions -> System.Threading.Tasks.Task<Microsoft.ServiceBus.Messaging.EventHubReceiver>Public Function CreateReceiverAsync (partitionId As String, position As EventPosition, Optional epoch As Nullable(Of Long) = Nothing, Optional receiverOptions As ReceiverOptions = Nothing) As Task(Of EventHubReceiver)Parâmetros
- partitionId
- String
A ID da partição.
- position
- EventPosition
A inicialização EventPosition na qual começar a receber mensagens.
O valor da época. O serviço usa esse valor para impor a propriedade de partição/concessão.
- receiverOptions
- ReceiverOptions
Opções para um receptor do hub de eventos.
Retornos
Retorna Task<TResult>.
Aplica-se a
Azure SDK for .NET
Comentários
Em breve: Ao longo de 2024, eliminaremos os problemas do GitHub como o mecanismo de comentários para conteúdo e o substituiremos por um novo sistema de comentários. Para obter mais informações, consulte https://aka.ms/ContentUserFeedback.
Enviar e exibir comentários de