Package | Description |
---|---|
com.azure.messaging.eventhubs |
Package containing classes for creating
EventHubProducerAsyncClient ,
EventHubProducerClient ,
EventHubConsumerAsyncClient ,
EventHubConsumerClient , or
EventProcessorClient to perform operations on Azure Event Hubs. |
com.azure.messaging.eventhubs.models |
Package containing classes used for creating and configuring events that are being sent-to and received-from Azure
Event Hubs service.
|
Modifier and Type | Method and Description |
---|---|
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,
ReceiveOptions receiveOptions)
Consumes events from a single partition starting at
startingPosition with a set of receive options . |
IterableStream<PartitionEvent> |
EventHubConsumerClient.receiveFromPartition(String partitionId,
int maximumMessageCount,
EventPosition startingPosition,
Duration maximumWaitTime,
ReceiveOptions receiveOptions)
Receives a batch of
events from the Event Hub partition. |
Modifier and Type | Method and Description |
---|---|
ReceiveOptions |
ReceiveOptions.setOwnerLevel(Long priority)
Sets the
ownerLevel value on this receive operation. |
ReceiveOptions |
ReceiveOptions.setTrackLastEnqueuedEventProperties(boolean trackLastEnqueuedEventProperties)
Sets whether or not the receive operation should request information on the last enqueued event on its associated
partition, and track that information as events are received.
|
Copyright © 2019 Microsoft Corporation. All rights reserved.