Uses of Class
com.azure.messaging.eventhubs.models.PartitionOwnership
Packages that use 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
Methods in com.azure.messaging.eventhubs that return types with arguments of type PartitionOwnershipModifier 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.Method parameters in com.azure.messaging.eventhubs with type arguments of type PartitionOwnershipModifier 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
Methods in com.azure.messaging.eventhubs.checkpointstore.blob that return types with arguments of type PartitionOwnershipModifier 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.Method parameters in com.azure.messaging.eventhubs.checkpointstore.blob with type arguments of type PartitionOwnershipModifier 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
Methods in com.azure.messaging.eventhubs.checkpointstore.jedis that return types with arguments of type PartitionOwnershipModifier 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.Method parameters in com.azure.messaging.eventhubs.checkpointstore.jedis with type arguments of type PartitionOwnershipModifier 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
Methods in com.azure.messaging.eventhubs.models that return PartitionOwnershipModifier 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.