Partager via


EventHubConsumerGroup.CreateReceiverAsync Méthode

Définition

Surcharges

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

Version asynchrone de CreateReceiver(String, String, Boolean, Int64, ReceiverOptions).

CreateReceiverAsync(String, String, Int64, ReceiverOptions)

Version asynchrone de CreateReceiver(String, String, Int64, ReceiverOptions).

CreateReceiverAsync(String, String, Boolean, ReceiverOptions)

Version asynchrone de CreateReceiver(String, String, Boolean, ReceiverOptions).

CreateReceiverAsync(String, DateTime, Int64, ReceiverOptions)

Version asynchrone de CreateReceiver(String, DateTime, Int64, ReceiverOptions).

CreateReceiverAsync(String, DateTime, ReceiverOptions)

Version asynchrone de CreateReceiver(String, DateTime, ReceiverOptions).

CreateReceiverAsync(String, String, ReceiverOptions)

Version asynchrone de CreateReceiver(String, ReceiverOptions).

CreateReceiverAsync(String, Int64, ReceiverOptions)

Version asynchrone de CreateReceiver(String, Int64, ReceiverOptions).

CreateReceiverAsync(String, ReceiverOptions)

Version asynchrone de CreateReceiver(String, ReceiverOptions).

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

Version asynchrone de CreateReceiver(String, EventPosition, Nullable<Int64>, ReceiverOptions).

CreateReceiverAsync(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)

Paramètres

partitionId
String

ID de la partition.

startingOffset
String

Décalage de départ auquel commencer à recevoir des messages.

offsetInclusive
Boolean

Valeur booléenne qui indique si startingOffset est traité comme un décalage inclusif, ce qui signifie que le premier événement retourné est l’événement qui contient le décalage de départ. Normalement, le premier événement retourné est l’événement après le décalage de début.

epoch
Int64

Valeur d’époque. Le service utilise cette valeur pour appliquer la propriété de la partition/du bail.

receiverOptions
ReceiverOptions

Options pour un récepteur event hub.

Retours

Retourne Task<TResult>.

S’applique à

CreateReceiverAsync(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)

Paramètres

partitionId
String

ID de la partition.

startingOffset
String

Décalage de départ auquel commencer à recevoir des messages. Pour spécifier le début du flux, consultez StartOfStream.

epoch
Int64

Valeur d’époque. Le service utilise cette valeur pour appliquer la propriété de la partition/du bail.

receiverOptions
ReceiverOptions

Options pour un récepteur event hub.

Retours

Retourne Task<TResult>.

S’applique à

CreateReceiverAsync(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)

Paramètres

partitionId
String

ID de la partition.

startingOffset
String

Décalage de départ auquel commencer à recevoir des messages.

offsetInclusive
Boolean

Valeur booléenne qui indique si startingOffset est traité comme un décalage inclusif, ce qui signifie que le premier événement retourné est l’événement qui contient le décalage de départ. Normalement, le premier événement retourné est l’événement après le décalage de début.

receiverOptions
ReceiverOptions

Options pour un récepteur event hub.

Retours

Retourne Task<TResult>.

S’applique à

CreateReceiverAsync(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)

Paramètres

partitionId
String

ID de la partition.

startingDateTimeUtc
DateTime

Heure UTC de début de la réception des messages.

epoch
Int64

Valeur d’époque. Le service utilise cette valeur pour appliquer la propriété de la partition/du bail.

receiverOptions
ReceiverOptions

Options pour un récepteur event hub.

Retours

Retourne Task<TResult>.

Remarques

Le service l’utilise startingDateTimeUtc uniquement comme approximation lors de la détermination de l’événement suivant à remettre.

Gardez à l’esprit qu’il peut y avoir un décalage d’horloge entre l’heure du client et l’heure du service, de sorte que l’application utilisateur doit être conçue pour gérer la duplication dans la remise d’événements.

S’applique à

CreateReceiverAsync(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)

Paramètres

partitionId
String

ID de la partition.

startingDateTimeUtc
DateTime

Heure UTC de début de la réception des messages.

receiverOptions
ReceiverOptions

Options pour un récepteur event hub.

Retours

Retourne Task<TResult>.

Remarques

Le service ne l’utilise startingDateTimeUtc qu’en tant qu’approximation lors de la détermination de l’événement suivant à remettre.

Gardez à l’esprit qu’il peut y avoir un décalage d’horloge entre l’heure du client et l’heure du service, de sorte que l’application utilisateur doit être conçue pour gérer la duplication dans la remise d’événements.

S’applique à

CreateReceiverAsync(String, 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)

Paramètres

partitionId
String

ID de la partition.

startingOffset
String

Décalage de départ auquel commencer à recevoir des messages.

receiverOptions
ReceiverOptions

Options pour un récepteur event hub.

Retours

Retourne Task<TResult>.

S’applique à

CreateReceiverAsync(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)

Paramètres

partitionId
String

ID de la partition.

epoch
Int64

Valeur d’époque. Le service utilise cette valeur pour appliquer la propriété de la partition/du bail.

receiverOptions
ReceiverOptions

Options pour un récepteur event hub.

Retours

Retourne Task<TResult>.

Remarques

Si le point de EventHubConsumerGroup contrôle est activé, le destinataire obtient le message suivant à partir du décalage du point de contrôle. Si le point de contrôle est désactivé, le récepteur obtient le message dès le début du flux d’événements, comme déterminé par la stratégie de rétention des messages de l’Event Hub.

S’applique à

CreateReceiverAsync(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)

Paramètres

partitionId
String

ID de la partition.

receiverOptions
ReceiverOptions

Options pour un récepteur event hub.

Retours

Retourne Task<TResult>.

Remarques

Si le point de EventHubConsumerGroup contrôle est activé, cette surcharge lève toujours InvalidOperationException, car le point de contrôle avec ConsumerGroup nécessite le fonctionnement de l’époque (utilisez la surcharge qui fournit l’époque comme argument d’entrée). Si le point de contrôle est désactivé, le récepteur obtient le message dès le début du flux d’événements, comme déterminé par la stratégie de rétention des messages de l’Event Hub.

S’applique à

CreateReceiverAsync(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)

Paramètres

partitionId
String

ID de la partition.

position
EventPosition

à partir EventPosition duquel commencer à recevoir des messages.

epoch
Nullable<Int64>

Valeur d’époque. Le service utilise cette valeur pour appliquer la propriété de la partition/du bail.

receiverOptions
ReceiverOptions

Options pour un récepteur event hub.

Retours

Retourne Task<TResult>.

S’applique à