-
Notifications
You must be signed in to change notification settings - Fork 593
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Move Partition retrieval functions to separate class (#827)
Co-authored-by: supereddie <>
- Loading branch information
1 parent
416f0a8
commit 9dcf317
Showing
3 changed files
with
197 additions
and
68 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,23 @@ | ||
| using System; | ||
| using System.Collections.Generic; | ||
| using Microsoft.ServiceBus.Messaging; | ||
|
|
||
| namespace ServiceBusExplorer.WindowsAzure | ||
| { | ||
| internal interface IServiceBusPartition : IServiceBusEntity | ||
| { | ||
| PartitionDescription GetPartition(PartitionDescription partitionDescription); | ||
|
|
||
| PartitionDescription GetPartition(string path, string consumerGroupName, string name); | ||
|
|
||
| IEnumerable<PartitionDescription> GetPartitions(EventHubDescription description); | ||
|
|
||
| IEnumerable<PartitionDescription> GetPartitions(EventHubDescription description, string consumerGroupName); | ||
|
|
||
| IEnumerable<PartitionDescription> GetPartitions(string path); | ||
|
|
||
| IEnumerable<PartitionDescription> GetPartitions(string path, string consumerGroupName); | ||
|
|
||
| Uri GetPartitionUri(string eventHubName, string consumerGroupName, string partitionId); | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,159 @@ | ||
| using System; | ||
| using System.Collections.Generic; | ||
| using System.Linq; | ||
| using Microsoft.ServiceBus; | ||
| using Microsoft.ServiceBus.Messaging; | ||
| using ServiceBusExplorer.Enums; | ||
| using ServiceBusExplorer.Helpers; | ||
|
|
||
| namespace ServiceBusExplorer.WindowsAzure | ||
| { | ||
| internal class ServiceBusPartition : ServiceBusEntity, IServiceBusPartition | ||
| { | ||
| private const string EventHubDescriptionCannotBeNull = "The event hub description argument cannot be null."; | ||
| private const string ConsumerGroupCannotBeNull = "The consumerGroup argument cannot be null or empty."; | ||
| private const string PartitionDescriptionCannotBeNull = "The partition description argument cannot be null."; | ||
|
|
||
| private readonly string servicePath = string.Empty; | ||
|
|
||
| public ServiceBusPartition(ServiceBusNamespace serviceBusNamespace, NamespaceManager namespaceManager) : base(serviceBusNamespace, namespaceManager) | ||
| { | ||
| } | ||
|
|
||
| protected override EntityType EntityType => EntityType.All; // Partitions are not included in the EntityType enum | ||
|
|
||
| /// <summary> | ||
| /// Retrieves a partition. | ||
| /// </summary> | ||
| /// <param name="partitionDescription">A PartitionDescription object.</param> | ||
| /// <returns>Returns an IEnumerable<SubscriptionDescription/> collection of partitions attached to the event hub passed as a parameter.</returns> | ||
| public PartitionDescription GetPartition(PartitionDescription partitionDescription) | ||
| { | ||
| if (partitionDescription == null) | ||
| { | ||
| throw new ArgumentException(PartitionDescriptionCannotBeNull); | ||
| } | ||
| if (NamespaceManager != null) | ||
| { | ||
| return RetryHelper.RetryFunc(() => NamespaceManager.GetEventHubPartition(partitionDescription.EventHubPath, partitionDescription.ConsumerGroupName, partitionDescription.PartitionId), WriteToLog); | ||
| } | ||
| throw new ApplicationException(ServiceBusIsDisconnected); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Retrieves a partition. | ||
| /// </summary> | ||
| /// <param name="path">Path of the event hub relative to the service namespace base address.</param> | ||
| /// <param name="consumerGroupName">The consumer group name.</param> | ||
| /// <param name="name">Partition name.</param> | ||
| /// <returns>Returns an IEnumerable<SubscriptionDescription/> collection of partitions attached to the event hub passed as a parameter.</returns> | ||
| public PartitionDescription GetPartition(string path, string consumerGroupName, string name) | ||
| { | ||
| if (string.IsNullOrWhiteSpace(path)) | ||
| { | ||
| throw new ArgumentException(PathCannotBeNull); | ||
| } | ||
| if (NamespaceManager != null) | ||
| { | ||
| return RetryHelper.RetryFunc(() => NamespaceManager.GetEventHubPartition(path, consumerGroupName, name), WriteToLog); | ||
| } | ||
| throw new ApplicationException(ServiceBusIsDisconnected); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Retrieves the collection of partitions of the event hub passed as a parameter. | ||
| /// </summary> | ||
| /// <param name="path">Path of the event hub relative to the service namespace base address.</param> | ||
| /// <returns>Returns an IEnumerable<SubscriptionDescription/> collection of partitions attached to the event hub passed as a parameter.</returns> | ||
| public IEnumerable<PartitionDescription> GetPartitions(string path) | ||
| { | ||
| if (string.IsNullOrWhiteSpace(path)) | ||
| { | ||
| throw new ArgumentException(PathCannotBeNull); | ||
| } | ||
| if (NamespaceManager == null) | ||
| { | ||
| throw new ApplicationException(ServiceBusIsDisconnected); | ||
| } | ||
| var description = NamespaceManager.GetEventHub(path); | ||
| return description.PartitionIds.Select((t, i) => i).Select(index => RetryHelper.RetryFunc(() => NamespaceManager.GetEventHubPartition(description.Path, description.PartitionIds[index]), WriteToLog)).ToList(); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Retrieves the collection of partitions of the event hub passed as a parameter. | ||
| /// </summary> | ||
| /// <param name="description">A event hub belonging to the current service namespace base.</param> | ||
| /// <returns>Returns an IEnumerable<SubscriptionDescription/> collection of partitions attached to the event hub passed as a parameter.</returns> | ||
| public IEnumerable<PartitionDescription> GetPartitions(EventHubDescription description) | ||
| { | ||
| if (description == null) | ||
| { | ||
| throw new ArgumentException(EventHubDescriptionCannotBeNull); | ||
| } | ||
| if (NamespaceManager != null) | ||
| { | ||
| return description.PartitionIds.Select((t, i) => i).Select(index => RetryHelper.RetryFunc(() => NamespaceManager.GetEventHubPartition(description.Path, description.PartitionIds[index]), WriteToLog)).ToList(); | ||
| } | ||
| throw new ApplicationException(ServiceBusIsDisconnected); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Retrieves the collection of partitions of the event hub passed as a parameter. | ||
| /// </summary> | ||
| /// <param name="description">A event hub belonging to the current service namespace base.</param> | ||
| /// <param name="consumerGroupName">The consumer group name.</param> | ||
| /// <returns>Returns an IEnumerable<SubscriptionDescription/> collection of partitions attached to the event hub passed as a parameter.</returns> | ||
| public IEnumerable<PartitionDescription> GetPartitions(EventHubDescription description, string consumerGroupName) | ||
| { | ||
| if (description == null) | ||
| { | ||
| throw new ArgumentException(EventHubDescriptionCannotBeNull); | ||
| } | ||
| if (string.IsNullOrWhiteSpace(consumerGroupName)) | ||
| { | ||
| throw new ArgumentException(ConsumerGroupCannotBeNull); | ||
| } | ||
| if (NamespaceManager != null) | ||
| { | ||
| return description.PartitionIds.Select((t, i) => i).Select(index => RetryHelper.RetryFunc(() => NamespaceManager.GetEventHubPartition(description.Path, consumerGroupName, description.PartitionIds[index]), WriteToLog)).ToList(); | ||
| } | ||
| throw new ApplicationException(ServiceBusIsDisconnected); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Retrieves the collection of partitions of the event hub passed as a parameter. | ||
| /// </summary> | ||
| /// <param name="path">Path of the event hub relative to the service namespace base address.</param> | ||
| /// <param name="consumerGroupName">The consumer group name.</param> | ||
| /// <returns>Returns an IEnumerable<SubscriptionDescription/> collection of partitions attached to the event hub passed as a parameter.</returns> | ||
| public IEnumerable<PartitionDescription> GetPartitions(string path, string consumerGroupName) | ||
| { | ||
| if (string.IsNullOrWhiteSpace(path)) | ||
| { | ||
| throw new ArgumentException(PathCannotBeNull); | ||
| } | ||
| if (string.IsNullOrWhiteSpace(consumerGroupName)) | ||
| { | ||
| throw new ArgumentException(ConsumerGroupCannotBeNull); | ||
| } | ||
| if (NamespaceManager != null) | ||
| { | ||
| var description = NamespaceManager.GetEventHub(path); | ||
| return description.PartitionIds.Select((t, i) => i).Select(index => RetryHelper.RetryFunc(() => NamespaceManager.GetEventHubPartition(description.Path, consumerGroupName, description.PartitionIds[index]), WriteToLog)).ToList(); | ||
| } | ||
| throw new ApplicationException(ServiceBusIsDisconnected); | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// Gets the uri of a partition. | ||
| /// </summary> | ||
| /// <param name="eventHubName">Name of the event hub.</param> | ||
| /// <param name="consumerGroupName">Name of the partition.</param> | ||
| /// <param name="partitionId">The partition id.</param> | ||
| /// <returns>The absolute uri of the partition.</returns> | ||
| public Uri GetPartitionUri(string eventHubName, string consumerGroupName, string partitionId) | ||
| { | ||
| return Microsoft.ServiceBus.ServiceBusEnvironment.CreateServiceUri(Scheme, Namespace, string.Concat(servicePath, eventHubName, "/", consumerGroupName, "/", partitionId)); | ||
| } | ||
| } | ||
| } |