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

Важно!

Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.

Абстракция в классе EventhubReceiver, используемая для настройки класса EventHubReceiver в EventhubAdapterReceiver, также используется для настройки EHGeneratorReceiver в EventHubAdapterReceiver для тестирования

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

Реализации

ReceiveAsync(Int32, TimeSpan)

Применяется к

Поделиться через