EventHubConsumerGroup.CreateReceiverAsync Método
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í.
Sobrecargas
CreateReceiverAsync(String, String, Boolean, Int64, ReceiverOptions)
Versión asincrónica 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
Identificador de la partición.
- startingOffset
- String
Desplazamiento inicial en el que se empiezan a recibir mensajes.
- offsetInclusive
- Boolean
Valor booleano que indica si startingOffset se trata como un desplazamiento inclusivo, lo que significa que el primer evento devuelto es el evento que contiene el desplazamiento inicial. Normalmente, el primer evento devuelto es el evento después del desplazamiento inicial.
- epoch
- Int64
Valor de época. El servicio usa este valor para aplicar la propiedad de partición o concesión.
- receiverOptions
- ReceiverOptions
Opciones para un receptor de centro de eventos.
Devoluciones
Devuelve Task<TResult>.
Se aplica a
CreateReceiverAsync(String, String, Int64, ReceiverOptions)
Versión asincrónica 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
Identificador de la partición.
- startingOffset
- String
Desplazamiento inicial en el que se empiezan a recibir mensajes. Para especificar el inicio de la secuencia, vea StartOfStream.
- epoch
- Int64
Valor de época. El servicio usa este valor para aplicar la propiedad de partición o concesión.
- receiverOptions
- ReceiverOptions
Opciones para un receptor de centro de eventos.
Devoluciones
Devuelve Task<TResult>.
Se aplica a
CreateReceiverAsync(String, String, Boolean, ReceiverOptions)
Versión asincrónica 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
Identificador de la partición.
- startingOffset
- String
Desplazamiento inicial en el que se empiezan a recibir mensajes.
- offsetInclusive
- Boolean
Valor booleano que indica si startingOffset se trata como un desplazamiento inclusivo, lo que significa que el primer evento devuelto es el evento que contiene el desplazamiento inicial. Normalmente, el primer evento devuelto es el evento después del desplazamiento inicial.
- receiverOptions
- ReceiverOptions
Opciones para un receptor de centro de eventos.
Devoluciones
Devuelve Task<TResult>.
Se aplica a
CreateReceiverAsync(String, DateTime, Int64, ReceiverOptions)
Versión asincrónica 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
Identificador de la partición.
- startingDateTimeUtc
- DateTime
Hora UTC inicial para recibir mensajes.
- epoch
- Int64
Valor de época. El servicio usa este valor para aplicar la propiedad de partición o concesión.
- receiverOptions
- ReceiverOptions
Opciones para un receptor de centro de eventos.
Devoluciones
Devuelve Task<TResult>.
Comentarios
El servicio solo lo usa startingDateTimeUtc como aproximación al determinar el siguiente evento que se va a entregar.
Tenga en cuenta que puede haber asimetría de reloj entre la hora del cliente y la hora del servicio, por lo que la aplicación de usuario debe diseñarse para controlar la duplicación en la entrega de eventos.
Se aplica a
CreateReceiverAsync(String, DateTime, ReceiverOptions)
Versión asincrónica 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
Identificador de la partición.
- startingDateTimeUtc
- DateTime
Hora UTC inicial para recibir mensajes.
- receiverOptions
- ReceiverOptions
Opciones para un receptor de centro de eventos.
Devoluciones
Devuelve Task<TResult>.
Comentarios
El servicio solo lo usa startingDateTimeUtc como aproximación al determinar el siguiente evento que se va a entregar.
Tenga en cuenta que puede haber asimetría de reloj entre la hora del cliente y la hora del servicio, por lo que la aplicación de usuario debe diseñarse para controlar la duplicación en la entrega de eventos.
Se aplica a
CreateReceiverAsync(String, String, ReceiverOptions)
Versión asincrónica 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
Identificador de la partición.
- startingOffset
- String
Desplazamiento inicial en el que se empiezan a recibir mensajes.
- receiverOptions
- ReceiverOptions
Opciones para un receptor de centro de eventos.
Devoluciones
Devuelve Task<TResult>.
Se aplica a
CreateReceiverAsync(String, Int64, ReceiverOptions)
Versión asincrónica 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
Identificador de la partición.
- epoch
- Int64
Valor de época. El servicio usa este valor para aplicar la propiedad de partición o concesión.
- receiverOptions
- ReceiverOptions
Opciones para un receptor de centro de eventos.
Devoluciones
Devuelve Task<TResult>.
Comentarios
Si el control EventHubConsumerGroup tiene habilitado el punto de control, el receptor recibirá el siguiente mensaje del desplazamiento del punto de control. Si el punto de control está deshabilitado, el receptor recibirá un mensaje desde el inicio de la secuencia de eventos, según lo determinado por la directiva de retención de mensajes del centro de eventos.
Se aplica a
CreateReceiverAsync(String, ReceiverOptions)
Versión asincrónica 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
Identificador de la partición.
- receiverOptions
- ReceiverOptions
Opciones para un receptor de centro de eventos.
Devoluciones
Devuelve Task<TResult>.
Comentarios
Si tiene habilitado el EventHubConsumerGroup punto de control, esta sobrecarga siempre iniciará InvalidOperationException porque el punto de control habilitado para ConsumerGroup requiere época para funcionar (use la sobrecarga que proporciona la época como argumento de entrada). Si el punto de control está deshabilitado, el receptor recibirá un mensaje desde el inicio de la secuencia de eventos, según lo determinado por la directiva de retención de mensajes del centro de eventos.
Se aplica a
CreateReceiverAsync(String, EventPosition, Nullable<Int64>, ReceiverOptions)
Versión asincrónica 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
Identificador de la partición.
- position
- EventPosition
A partir del cual se empiezan EventPosition a recibir mensajes.
Valor de época. El servicio usa este valor para aplicar la propiedad de partición o concesión.
- receiverOptions
- ReceiverOptions
Opciones para un receptor de centro de eventos.
Devoluciones
Devuelve Task<TResult>.
Se aplica a
Azure SDK for .NET
Comentarios
Próximamente: A lo largo de 2024 iremos eliminando gradualmente GitHub Issues como mecanismo de comentarios sobre el contenido y lo sustituiremos por un nuevo sistema de comentarios. Para más información, vea: https://aka.ms/ContentUserFeedback.
Enviar y ver comentarios de