Freigeben über


EventHubConsumerGroup.CreateReceiverAsync Methode

Definition

Überlädt

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

Asynchrone Version von CreateReceiver(String, String, Boolean, Int64, ReceiverOptions).

CreateReceiverAsync(String, String, Int64, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, String, Int64, ReceiverOptions).

CreateReceiverAsync(String, String, Boolean, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, String, Boolean, ReceiverOptions).

CreateReceiverAsync(String, DateTime, Int64, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, DateTime, Int64, ReceiverOptions).

CreateReceiverAsync(String, DateTime, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, DateTime, ReceiverOptions).

CreateReceiverAsync(String, String, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, ReceiverOptions).

CreateReceiverAsync(String, Int64, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, Int64, ReceiverOptions).

CreateReceiverAsync(String, ReceiverOptions)

Asynchrone Version von CreateReceiver(String, ReceiverOptions).

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

Asynchrone Version von 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)

Parameter

partitionId
String

Die ID der Partition.

startingOffset
String

Der Startoffset, ab dem mit dem Empfang von Nachrichten begonnen werden soll.

offsetInclusive
Boolean

Ein boolescher Wert, der angibt, ob startingOffset als inklusiver Offset behandelt wird, was bedeutet, dass das erste zurückgegebene Ereignis das Ereignis ist, das den Startoffset enthält. Normalerweise ist das erste zurückgegebene Ereignis das Ereignis nach dem Startoffset.

epoch
Int64

Der Epochenwert. Der Dienst verwendet diesen Wert, um den Partitions-/Leasebesitz zu erzwingen.

receiverOptions
ReceiverOptions

Optionen für einen Event Hub-Empfänger.

Gibt zurück

Gibt Task<TResult>zurück.

Gilt für:

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)

Parameter

partitionId
String

Die ID der Partition.

startingOffset
String

Der Startoffset, ab dem mit dem Empfang von Nachrichten begonnen werden soll. Informationen zum Angeben des Anfangs des Datenstroms finden Sie unter StartOfStream.

epoch
Int64

Der Epochenwert. Der Dienst verwendet diesen Wert, um den Partitions-/Leasebesitz zu erzwingen.

receiverOptions
ReceiverOptions

Optionen für einen Event Hub-Empfänger.

Gibt zurück

Gibt Task<TResult>zurück.

Gilt für:

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)

Parameter

partitionId
String

Die ID der Partition.

startingOffset
String

Der Startoffset, ab dem mit dem Empfang von Nachrichten begonnen werden soll.

offsetInclusive
Boolean

Ein boolescher Wert, der angibt, ob startingOffset als inklusiver Offset behandelt wird, was bedeutet, dass das erste zurückgegebene Ereignis das Ereignis ist, das den Startoffset enthält. Normalerweise ist das erste zurückgegebene Ereignis das Ereignis nach dem Startoffset.

receiverOptions
ReceiverOptions

Optionen für einen Event Hub-Empfänger.

Gibt zurück

Gibt Task<TResult>zurück.

Gilt für:

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)

Parameter

partitionId
String

Die ID der Partition.

startingDateTimeUtc
DateTime

Die UTC-Startzeit für den Empfang von Nachrichten.

epoch
Int64

Der Epochenwert. Der Dienst verwendet diesen Wert, um den Partitions-/Leasebesitz zu erzwingen.

receiverOptions
ReceiverOptions

Optionen für einen Event Hub-Empfänger.

Gibt zurück

Gibt Task<TResult>zurück.

Hinweise

Der Dienst verwendet dies startingDateTimeUtc nur als Näherung, wenn das nächste zu übermittelnde Ereignis bestimmt wird.

Beachten Sie, dass zwischen Clientzeit und Dienstzeit eine Abweichung der Uhr auftreten kann. Daher sollte die Benutzeranwendung so konzipiert werden, dass sie duplizierungen bei der Ereignisübermittlung verarbeitet.

Gilt für:

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)

Parameter

partitionId
String

Die ID der Partition.

startingDateTimeUtc
DateTime

Die UTC-Startzeit für den Empfang von Nachrichten.

receiverOptions
ReceiverOptions

Optionen für einen Event Hub-Empfänger.

Gibt zurück

Gibt Task<TResult>zurück.

Hinweise

Der Dienst verwendet dies startingDateTimeUtc nur als Näherung, wenn das nächste zu übermittelnde Ereignis bestimmt wird.

Beachten Sie, dass zwischen Clientzeit und Dienstzeit eine Abweichung der Uhr auftreten kann. Daher sollte die Benutzeranwendung so konzipiert werden, dass sie duplizierungen bei der Ereignisübermittlung verarbeitet.

Gilt für:

CreateReceiverAsync(String, String, ReceiverOptions)

Asynchrone Version von 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)

Parameter

partitionId
String

Die ID der Partition.

startingOffset
String

Der Startoffset, ab dem mit dem Empfang von Nachrichten begonnen werden soll.

receiverOptions
ReceiverOptions

Optionen für einen Event Hub-Empfänger.

Gibt zurück

Gibt Task<TResult>zurück.

Gilt für:

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)

Parameter

partitionId
String

Die ID der Partition.

epoch
Int64

Der Epochenwert. Der Dienst verwendet diesen Wert, um den Partitions-/Leasebesitz zu erzwingen.

receiverOptions
ReceiverOptions

Optionen für einen Event Hub-Empfänger.

Gibt zurück

Gibt Task<TResult>zurück.

Hinweise

Wenn der EventHubConsumerGroup Prüfpunkt aktiviert ist, erhält der Empfänger die nächste Nachricht vom Prüfpunktoffset. Wenn der Prüfpunkt deaktiviert ist, erhält der Empfänger eine Nachricht vom Anfang des Ereignisdatenstroms, wie durch die Nachrichtenaufbewahrungsrichtlinie des Event Hubs festgelegt.

Gilt für:

CreateReceiverAsync(String, ReceiverOptions)

Asynchrone Version von 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)

Parameter

partitionId
String

Die ID der Partition.

receiverOptions
ReceiverOptions

Optionen für einen Event Hub-Empfänger.

Gibt zurück

Gibt Task<TResult>zurück.

Hinweise

Wenn der EventHubConsumerGroup Prüfpunkt aktiviert ist, löst diese Überladung immer InvalidOperationException aus, da die consumerGroup für Prüfpunkte aktiviert ist, um eine Epoche zu funktionieren (verwenden Sie die Überladung, die Epoche als Eingabeargument bereitstellt). Wenn der Prüfpunkt deaktiviert ist, erhält der Empfänger eine Nachricht vom Anfang des Ereignisdatenstroms, wie durch die Nachrichtenaufbewahrungsrichtlinie des Event Hubs festgelegt.

Gilt für:

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)

Parameter

partitionId
String

Die ID der Partition.

position
EventPosition

Die , EventPosition ab der nachrichten empfangen werden sollen.

epoch
Nullable<Int64>

Der Epochenwert. Der Dienst verwendet diesen Wert, um den Partitions-/Leasebesitz zu erzwingen.

receiverOptions
ReceiverOptions

Optionen für einen Event Hub-Empfänger.

Gibt zurück

Gibt Task<TResult>zurück.

Gilt für: