EventHubPartitionGeneratorReceiver.ReceiveAsync(Int32, TimeSpan) Methode

Referenz

Definition

Namespace:: Orleans.ServiceBus.Providers.Testing

Assembly:: OrleansServiceBus.dll

Assembly:: Orleans.Streaming.EventHubs.dll

Paket:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Paket:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Paket:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Quelle:: EventHubPartitionGeneratorReceiver.cs

Wichtig

Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.

Abstraktion auf eventhubReceiver-Klasse, die zum Konfigurieren der EventHubReceiver-Klasse in EventhubAdapterReceiver verwendet wird, auch zum Konfigurieren von EHGeneratorReceiver in EventHubAdapterReceiver für Testzwecke

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

Parameter

maxCount: Int32

waitTime: TimeSpan

Gibt zurück

Task<IEnumerable<EventData>>

Implementiert

ReceiveAsync(Int32, TimeSpan)

Gilt für:

Freigeben über