EventHubPartitionGeneratorReceiver.ReceiveAsync(Int32, TimeSpan) メソッド

  • リファレンス

定義

名前空間:
Orleans.ServiceBus.Providers.Testing
アセンブリ:
OrleansServiceBus.dll
アセンブリ:
Orleans.Streaming.EventHubs.dll
パッケージ:
Microsoft.Orleans.OrleansServiceBus v1.5.10
パッケージ:
Microsoft.Orleans.OrleansServiceBus v2.4.5
パッケージ:
Microsoft.Orleans.OrleansServiceBus v3.6.5
ソース:
EventHubPartitionGeneratorReceiver.cs

EventhubAdapterReceiver で EventHubReceiver クラスを構成するために使用される EventhubReceiver クラスの抽象化。また、テスト目的で EventHubAdapterReceiver で EHGeneratorReceiver を構成するために使用されます

public System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Microsoft.ServiceBus.Messaging.EventData>> ReceiveAsync (int maxCount, TimeSpan waitTime);
public System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Microsoft.Azure.EventHubs.EventData>> ReceiveAsync (int maxCount, TimeSpan waitTime);
public System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.EventData>> ReceiveAsync (int maxCount, TimeSpan waitTime);
abstract member ReceiveAsync : int * TimeSpan -> System.Threading.Tasks.Task<seq<Microsoft.ServiceBus.Messaging.EventData>>
override this.ReceiveAsync : int * TimeSpan -> System.Threading.Tasks.Task<seq<Microsoft.ServiceBus.Messaging.EventData>>
abstract member ReceiveAsync : int * TimeSpan -> System.Threading.Tasks.Task<seq<Microsoft.Azure.EventHubs.EventData>>
override this.ReceiveAsync : int * TimeSpan -> System.Threading.Tasks.Task<seq<Microsoft.Azure.EventHubs.EventData>>
abstract member ReceiveAsync : int * TimeSpan -> System.Threading.Tasks.Task<seq<Azure.Messaging.EventHubs.EventData>>
override this.ReceiveAsync : int * TimeSpan -> System.Threading.Tasks.Task<seq<Azure.Messaging.EventHubs.EventData>>
Public Function ReceiveAsync (maxCount As Integer, waitTime As TimeSpan) As Task(Of IEnumerable(Of EventData))

パラメーター

maxCount
Int32
waitTime
TimeSpan

戻り値

Task<IEnumerable<EventData>>
Task<IEnumerable<EventData>>
Task<IEnumerable<EventData>>

実装

ReceiveAsync(Int32, TimeSpan)

適用対象