PartitionReceiver.ReceiveAsync Método

Definição

Namespace:

Microsoft.Azure.EventHubs

Assembly:

Microsoft.Azure.EventHubs.dll

Pacote:

Microsoft.Azure.EventHubs v4.3.2

Sobrecargas

ReceiveAsync(Int32)	Receber um lote de EventData's de uma partição do EventHub
ReceiveAsync(Int32, TimeSpan)	Receba um lote de EventData's de uma partição eventHub permitindo tempo de espera em cada chamada individual.

ReceiveAsync(Int32)

Origem:

PartitionReceiver.cs

Receber um lote de EventData's de uma partição do EventHub

public System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Microsoft.Azure.EventHubs.EventData>> ReceiveAsync (int maxMessageCount);

member this.ReceiveAsync : int -> System.Threading.Tasks.Task<seq<Microsoft.Azure.EventHubs.EventData>>

Public Function ReceiveAsync (maxMessageCount As Integer) As Task(Of IEnumerable(Of EventData))

Parâmetros

maxMessageCount

Int32

Retornos

Task<IEnumerable<EventData>>

Uma Tarefa que produzirá um lote de EventData da partição na qual esse receptor é criado. Retornará 'null' se nenhum EventData estiver presente.

Exemplos

Exemplo de código:

EventHubClient client = EventHubClient.Create("__connectionString__");
PartitionReceiver receiver = client.CreateReceiver("ConsumerGroup1", "1");
IEnumerable<EventData> receivedEvents = await receiver.ReceiveAsync(BatchSize);

while (true)
{
    int batchSize = 0;
    if (receivedEvents != null)
    {
        foreach (EventData receivedEvent in receivedEvents)
        {
            Console.WriteLine("Message Payload: {0}", Encoding.UTF8.GetString(receivedEvent.Body));
            Console.WriteLine("Offset: {0}, SeqNo: {1}, EnqueueTime: {2}", 
                receivedEvent.SystemProperties.Offset, 
                receivedEvent.SystemProperties.SequenceNumber, 
                receivedEvent.SystemProperties.EnqueuedTime);
            batchSize++;
        }
    }

    Console.WriteLine("ReceivedBatch Size: {0}", batchSize);
    receivedEvents = await receiver.ReceiveAsync();
}

ReceiveAsync(Int32, TimeSpan)

Origem:

PartitionReceiver.cs

Receba um lote de EventData's de uma partição eventHub permitindo tempo de espera em cada chamada individual.

public System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Microsoft.Azure.EventHubs.EventData>> ReceiveAsync (int maxMessageCount, TimeSpan waitTime);

member this.ReceiveAsync : int * TimeSpan -> System.Threading.Tasks.Task<seq<Microsoft.Azure.EventHubs.EventData>>

Public Function ReceiveAsync (maxMessageCount As Integer, waitTime As TimeSpan) As Task(Of IEnumerable(Of EventData))

Parâmetros

maxMessageCount

Int32

waitTime

TimeSpan

Retornos

Task<IEnumerable<EventData>>

Uma Tarefa que produzirá um lote de EventData da partição na qual esse receptor é criado. Retornará 'null' se nenhum EventData estiver presente.