Freigeben über

PartitionReceiver.ReceiveAsync Methode

  • Referenz

Definition

Namespace:
Microsoft.Azure.EventHubs
Assembly:
Microsoft.Azure.EventHubs.dll
Paket:
Microsoft.Azure.EventHubs v4.3.2

Überlädt

ReceiveAsync(Int32)

Empfangen eines Batches von EventData"s" von einer EventHub-Partition
ReceiveAsync(Int32, TimeSpan)

Erhalten Sie einen Batch von EventData"s" von einer EventHub-Partition, indem Sie wartezeiten für jeden einzelnen Aufruf zulassen.

ReceiveAsync(Int32)

Quelle:
PartitionReceiver.cs

Empfangen eines Batches von EventData"s" von einer EventHub-Partition

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

Parameter

maxMessageCount
Int32

Gibt zurück

Task<IEnumerable<EventData>>

Eine Aufgabe, die einen Batch von EventData aus der Partition ergibt, auf der dieser Empfänger erstellt wird. Gibt "null" zurück, wenn kein EventData vorhanden ist.

Beispiele

Beispielcode:

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();
}

Gilt für:

ReceiveAsync(Int32, TimeSpan)

Quelle:
PartitionReceiver.cs

Erhalten Sie einen Batch von EventData"s" von einer EventHub-Partition, indem Sie wartezeiten für jeden einzelnen Aufruf zulassen.

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

Parameter

maxMessageCount
Int32
waitTime
TimeSpan

Gibt zurück

Task<IEnumerable<EventData>>

Eine Aufgabe, die einen Batch von EventData aus der Partition ergibt, auf der dieser Empfänger erstellt wird. Gibt "null" zurück, wenn kein EventData vorhanden ist.

Gilt für: