EventHubConsumerGroup.CreateReceiverAsync メソッド
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
オーバーロード
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)パラメーター
- partitionId
- String
パーティションの ID。
- startingOffset
- String
メッセージの受信を開始する開始オフセット。
- offsetInclusive
- Boolean
が包括オフセットとして扱われるかどうかを startingOffset 示すブール値。つまり、返される最初のイベントは開始オフセットを含むイベントです。 通常、最初に返されるイベントは開始オフセットの後のイベントです。
- epoch
- Int64
エポック値。 サービスでは、この値を使用してパーティション/リース所有権を適用します。
- receiverOptions
- ReceiverOptions
イベント ハブ レシーバーのオプション。
戻り値
Task<TResult> を返します。
適用対象
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)パラメーター
- partitionId
- String
パーティションの ID。
- startingOffset
- String
メッセージの受信を開始する開始オフセット。 ストリームの開始を指定するには、「」を参照してください StartOfStream。
- epoch
- Int64
エポック値。 サービスでは、この値を使用してパーティション/リース所有権を適用します。
- receiverOptions
- ReceiverOptions
イベント ハブ レシーバーのオプション。
戻り値
Task<TResult> を返します。
適用対象
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)パラメーター
- partitionId
- String
パーティションの ID。
- startingOffset
- String
メッセージの受信を開始する開始オフセット。
- offsetInclusive
- Boolean
が包括オフセットとして扱われるかどうかを startingOffset 示すブール値。つまり、返される最初のイベントは開始オフセットを含むイベントです。 通常、最初に返されるイベントは開始オフセットの後のイベントです。
- receiverOptions
- ReceiverOptions
イベント ハブ レシーバーのオプション。
戻り値
Task<TResult> を返します。
適用対象
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)パラメーター
- partitionId
- String
パーティションの ID。
- startingDateTimeUtc
- DateTime
メッセージを受信するための開始 UTC 時刻。
- epoch
- Int64
エポック値。 サービスでは、この値を使用してパーティション/リース所有権を適用します。
- receiverOptions
- ReceiverOptions
イベント ハブ レシーバーのオプション。
戻り値
Task<TResult> を返します。
注釈
サービスでは、次に配信するイベントを決定するときに、これを startingDateTimeUtc 近似としてのみ使用します。
クライアント時刻とサービス時間の間にはクロック スキューが発生する可能性があるので、イベント配信での重複を処理するようにユーザー アプリケーションを設計する必要があることに注意してください。
適用対象
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)パラメーター
- partitionId
- String
パーティションの ID。
- startingDateTimeUtc
- DateTime
メッセージを受信するための開始 UTC 時刻。
- receiverOptions
- ReceiverOptions
イベント ハブ レシーバーのオプション。
戻り値
Task<TResult> を返します。
注釈
サービスは、配信する次のイベントを決定するときに、これを startingDateTimeUtc 近似値としてのみ使用します。
クライアント時刻とサービス時間の間にはクロック スキューが発生する可能性があるので、イベント配信での重複を処理するようにユーザー アプリケーションを設計する必要があることに注意してください。
適用対象
CreateReceiverAsync(String, String, ReceiverOptions)
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)パラメーター
- partitionId
- String
パーティションの ID。
- startingOffset
- String
メッセージの受信を開始する開始オフセット。
- receiverOptions
- ReceiverOptions
イベント ハブ レシーバーのオプション。
戻り値
Task<TResult> を返します。
適用対象
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)パラメーター
- partitionId
- String
パーティションの ID。
- epoch
- Int64
エポック値。 サービスでは、この値を使用してパーティション/リース所有権を適用します。
- receiverOptions
- ReceiverOptions
イベント ハブ レシーバーのオプション。
戻り値
Task<TResult> を返します。
注釈
に EventHubConsumerGroup チェックポイントが有効になっている場合、受信側はチェックポイント オフセットから次のメッセージを受け取ります。 チェックポイントが無効になっている場合、受信側は、イベント ハブのメッセージ保持ポリシーによって決定されたイベント ストリームの先頭からメッセージを受け取ります。
適用対象
CreateReceiverAsync(String, ReceiverOptions)
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)パラメーター
- partitionId
- String
パーティションの ID。
- receiverOptions
- ReceiverOptions
イベント ハブ レシーバーのオプション。
戻り値
Task<TResult> を返します。
注釈
チェックポイントが EventHubConsumerGroup 有効になっている場合、チェックポイントが有効な ConsumerGroup ではエポックが機能する必要があるため、このオーバーロードは常に InvalidOperationException をスローします (入力引数としてエポックを提供するオーバーロードを使用してください)。 チェックポイントが無効になっている場合、受信側は、イベント ハブのメッセージ保持ポリシーによって決定されたイベント ストリームの先頭からメッセージを受け取ります。
適用対象
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)パラメーター
- partitionId
- String
パーティションの ID。
- position
- EventPosition
メッセージの受信を EventPosition 開始する開始位置の 。
- receiverOptions
- ReceiverOptions
イベント ハブ レシーバーのオプション。
戻り値
Task<TResult> を返します。
適用対象
Azure SDK for .NET
フィードバック
以下は間もなく提供いたします。2024 年を通じて、コンテンツのフィードバック メカニズムとして GitHub の issue を段階的に廃止し、新しいフィードバック システムに置き換えます。 詳細については、「https://aka.ms/ContentUserFeedback」を参照してください。
フィードバックの送信と表示