Uses of Class
com.azure.messaging.eventhubs.models.PartitionEvent

Packages that use PartitionEvent

Package	Description
com.azure.messaging.eventhubs	Azure Event Hubs is a highly scalable publish-subscribe service that can ingest millions of events per second and stream them to multiple consumers.

Uses of PartitionEvent in com.azure.messaging.eventhubs

Methods in com.azure.messaging.eventhubs that return types with arguments of type PartitionEvent

Modifier and Type	Method	Description
Flux<PartitionEvent>	EventHubConsumerAsyncClient.receive()	Consumes events from all partitions starting from the beginning of each partition.
Flux<PartitionEvent>	EventHubConsumerAsyncClient.receive(boolean startReadingAtEarliestEvent)	Consumes events from all partitions.
Flux<PartitionEvent>	EventHubConsumerAsyncClient.receive(boolean startReadingAtEarliestEvent, ReceiveOptions receiveOptions)	Consumes events from all partitions configured with a set of receiveOptions.
Flux<PartitionEvent>	EventHubConsumerAsyncClient.receiveFromPartition(String partitionId, EventPosition startingPosition)	Consumes events from a single partition starting at startingPosition.
Flux<PartitionEvent>	EventHubConsumerAsyncClient.receiveFromPartition(String partitionId, EventPosition startingPosition, ReceiveOptions receiveOptions)	Consumes events from a single partition starting at startingPosition with a set of receive options.
com.azure.core.util.IterableStream<PartitionEvent>	EventHubConsumerClient.receiveFromPartition(String partitionId, int maximumMessageCount, EventPosition startingPosition)	Receives a batch of events from the Event Hub partition.
com.azure.core.util.IterableStream<PartitionEvent>	EventHubConsumerClient.receiveFromPartition(String partitionId, int maximumMessageCount, EventPosition startingPosition, Duration maximumWaitTime)	Receives a batch of events from the Event Hub partition.
com.azure.core.util.IterableStream<PartitionEvent>	EventHubConsumerClient.receiveFromPartition(String partitionId, int maximumMessageCount, EventPosition startingPosition, Duration maximumWaitTime, ReceiveOptions receiveOptions)	Receives a batch of events from the Event Hub partition.