Uses of Class
com.azure.messaging.eventhubs.models.PartitionOwnership
Package
Description
Package containing classes for creating
EventHubProducerAsyncClient
,
EventHubProducerClient
,
EventHubConsumerAsyncClient
,
EventHubConsumerClient
, or
EventProcessorClient
to perform operations on Azure Event Hubs.Package containing implementation for
CheckpointStore
that uses Storage
blobs for persisting checkpoints and partition ownership details.Package containing implementation of CheckpointStore that uses Azure Redis Cache, specifically Jedis.
Package containing classes used for creating and configuring events that are being sent-to and received-from Azure
Event Hubs service.
-
Uses of PartitionOwnership in com.azure.messaging.eventhubs
Modifier and TypeMethodDescriptionCheckpointStore.claimOwnership
(List<PartitionOwnership> requestedPartitionOwnerships) Called to claim ownership of a list of partitions.CheckpointStore.listOwnership
(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) Called to get the list of all existing partition ownership from the underlying data store.Modifier and TypeMethodDescriptionCheckpointStore.claimOwnership
(List<PartitionOwnership> requestedPartitionOwnerships) Called to claim ownership of a list of partitions. -
Uses of PartitionOwnership in com.azure.messaging.eventhubs.checkpointstore.blob
Modifier and TypeMethodDescriptionBlobCheckpointStore.claimOwnership
(List<PartitionOwnership> requestedPartitionOwnerships) This method is called by theEventProcessorClient
to claim ownership of a list of partitions.BlobCheckpointStore.listOwnership
(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) This method is called by theEventProcessorClient
to get the list of all existing partition ownership from the Storage Blobs.Modifier and TypeMethodDescriptionBlobCheckpointStore.claimOwnership
(List<PartitionOwnership> requestedPartitionOwnerships) This method is called by theEventProcessorClient
to claim ownership of a list of partitions. -
Uses of PartitionOwnership in com.azure.messaging.eventhubs.checkpointstore.jedis
Modifier and TypeMethodDescriptionJedisRedisCheckpointStore.claimOwnership
(List<PartitionOwnership> requestedPartitionOwnerships) This method returns the list of partitions that were owned successfully.JedisRedisCheckpointStore.listOwnership
(String fullyQualifiedNamespace, String eventHubName, String consumerGroup) This method returns the list of ownership records from the underlying data store, and if no ownership records are available, then it returns empty results.Modifier and TypeMethodDescriptionJedisRedisCheckpointStore.claimOwnership
(List<PartitionOwnership> requestedPartitionOwnerships) This method returns the list of partitions that were owned successfully. -
Uses of PartitionOwnership in com.azure.messaging.eventhubs.models
Modifier and TypeMethodDescriptionPartitionOwnership.setConsumerGroup
(String consumerGroup) Sets the consumer group name associated with this ownership record.Sets the ETag with the last known successful update to partition ownership record.PartitionOwnership.setEventHubName
(String eventHubName) Sets the Event Hub name associated with this ownership record.PartitionOwnership.setFullyQualifiedNamespace
(String fullyQualifiedNamespace) Sets the fully qualified namespace of the Event Hub.PartitionOwnership.setLastModifiedTime
(Long lastModifiedTime) Sets the last modified time of this ownership record as epoch millis.PartitionOwnership.setOwnerId
(String ownerId) Returns the unique event processor identifier that owns the partition id in this ownership record.PartitionOwnership.setPartitionId
(String partitionId) Sets the partition id associated with this ownership record.