PartitionReceiver.ReceiveAsync Método

Definición

Espacio de nombres:

Microsoft.Azure.EventHubs

Ensamblado:

Microsoft.Azure.EventHubs.dll

Paquete:

Microsoft.Azure.EventHubs v4.3.2

Sobrecargas

ReceiveAsync(Int32)	Recepción de un lote de EventDatade una partición de EventHub
ReceiveAsync(Int32, TimeSpan)	Reciba un lote de de una partición de EventHub al permitir el tiempo de EventDataespera en cada llamada individual.

ReceiveAsync(Int32)

Source:

PartitionReceiver.cs

Recepción de un lote de EventDatade una partición de 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

Devoluciones

Task<IEnumerable<EventData>>

Tarea que producirá un lote de EventData la partición en la que se crea este receptor. Devuelve 'null' si no hay ningún eventData presente.

Ejemplos

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

Source:

PartitionReceiver.cs

Reciba un lote de de una partición de EventHub al permitir el tiempo de EventDataespera en cada llamada 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

Devoluciones

Task<IEnumerable<EventData>>

Tarea que producirá un lote de EventData la partición en la que se crea este receptor. Devuelve 'null' si no hay ningún eventData presente.