Messaging: Remove Azure Storage Queue

Author: phongnguyend

src/Microservices/Common/ClassifiedAds.Infrastructure/ClassifiedAds.Infrastructure.csproj

@@ -16,7 +16,6 @@
     <PackageReference Include="Azure.Messaging.ServiceBus" Version="7.18.2" />
     <PackageReference Include="Azure.Monitor.OpenTelemetry.Exporter" Version="1.3.0" />
     <PackageReference Include="Azure.Storage.Blobs" Version="12.23.0" />
-    <PackageReference Include="Azure.Storage.Queues" Version="12.21.0" />
     <PackageReference Include="Castle.Core" Version="5.1.1" />
     <PackageReference Include="Confluent.Kafka" Version="2.8.0" />
     <PackageReference Include="CryptographyHelper" Version="3.1.0" />

src/Microservices/Common/ClassifiedAds.Infrastructure/HealthChecks/HealthCheckBuilderExtensions.cs

@@ -1,5 +1,4 @@
 using ClassifiedAds.Infrastructure.HealthChecks;
-using ClassifiedAds.Infrastructure.Messaging.AzureQueue;
 using ClassifiedAds.Infrastructure.Messaging.AzureServiceBus;
 using ClassifiedAds.Infrastructure.Messaging.Kafka;
 using ClassifiedAds.Infrastructure.Messaging.RabbitMQ;
@@ -79,25 +78,6 @@ public static IHealthChecksBuilder AddAzureBlobStorage(
             timeout));
     }
 
-    public static IHealthChecksBuilder AddAzureQueueStorage(
-        this IHealthChecksBuilder builder,
-        string connectionString,
-        string queueName,
-        string name = default,
-        HealthStatus? failureStatus = default,
-        IEnumerable<string> tags = default,
-        TimeSpan? timeout = default)
-    {
-        return builder.Add(new HealthCheckRegistration(
-            name,
-            new AzureQueueStorageHealthCheck(
-                connectionString: connectionString,
-                queueName: queueName),
-            failureStatus,
-            tags,
-            timeout));
-    }
-
     public static IHealthChecksBuilder AddAzureServiceBusQueue(
         this IHealthChecksBuilder builder,
         string connectionString,

src/Microservices/Common/ClassifiedAds.Infrastructure/Messaging/AzureQueue/AzureQueueOptions.cs

@@ -1,6 +1,5 @@
 using ClassifiedAds.Domain.Infrastructure.Messaging;
 using ClassifiedAds.Infrastructure.Messaging;
-using ClassifiedAds.Infrastructure.Messaging.AzureQueue;
 using ClassifiedAds.Infrastructure.Messaging.AzureServiceBus;
 using ClassifiedAds.Infrastructure.Messaging.Fake;
 using ClassifiedAds.Infrastructure.Messaging.Kafka;
@@ -12,22 +11,6 @@ namespace Microsoft.Extensions.DependencyInjection;
 
 public static class MessagingCollectionExtensions
 {
-    public static IServiceCollection AddAzureQueueSender<T>(this IServiceCollection services, AzureQueueOptions options)
-    {
-        services.AddSingleton<IMessageSender<T>>(new AzureQueueSender<T>(
-                            options.ConnectionString,
-                            options.QueueNames[typeof(T).Name]));
-        return services;
-    }
-
-    public static IServiceCollection AddAzureQueueReceiver<TConsumer, T>(this IServiceCollection services, AzureQueueOptions options)
-    {
-        services.AddTransient<IMessageReceiver<TConsumer, T>>(x => new AzureQueueReceiver<TConsumer, T>(
-                            options.ConnectionString,
-                            options.QueueNames[typeof(T).Name]));
-        return services;
-    }
-
     public static IServiceCollection AddAzureServiceBusSender<T>(this IServiceCollection services, AzureServiceBusOptions options)
     {
         services.AddSingleton<IMessageSender<T>>(new AzureServiceBusSender<T>(
@@ -114,10 +97,6 @@ public static IServiceCollection AddMessageBusSender<T>(this IServiceCollection
         {
             services.AddKafkaSender<T>(options.Kafka);
         }
-        else if (options.UsedAzureQueue())
-        {
-            services.AddAzureQueueSender<T>(options.AzureQueue);
-        }
         else if (options.UsedAzureServiceBus())
         {
             services.AddAzureServiceBusSender<T>(options.AzureServiceBus);
@@ -140,10 +119,6 @@ public static IServiceCollection AddMessageBusReceiver<TConsumer, T>(this IServi
         {
             services.AddKafkaReceiver<TConsumer, T>(options.Kafka);
         }
-        else if (options.UsedAzureQueue())
-        {
-            services.AddAzureQueueReceiver<TConsumer, T>(options.AzureQueue);
-        }
         else if (options.UsedAzureServiceBus())
         {
             services.AddAzureServiceBusReceiver<TConsumer, T>(options.AzureServiceBus);
@@ -180,16 +155,6 @@ public static IHealthChecksBuilder AddMessageBusHealthCheck(this IHealthChecksBu
                 name: name,
                 failureStatus: HealthStatus.Degraded);
         }
-        else if (options.UsedAzureQueue())
-        {
-            foreach (var queueName in options.AzureQueue.QueueNames)
-            {
-                healthChecksBuilder.AddAzureQueueStorage(connectionString: options.AzureQueue.ConnectionString,
-                    queueName: queueName.Value,
-                    name: $"Message Broker (Azure Queue) {queueName.Key}",
-                    failureStatus: HealthStatus.Degraded);
-            }
-        }
         else if (options.UsedAzureServiceBus())
         {
             foreach (var queueName in options.AzureServiceBus.QueueNames)

src/Microservices/Common/ClassifiedAds.Infrastructure/Messaging/AzureQueue/AzureQueueReceiver.cs

@@ -1,5 +1,4 @@
-using ClassifiedAds.Infrastructure.Messaging.AzureQueue;
-using ClassifiedAds.Infrastructure.Messaging.AzureServiceBus;
+using ClassifiedAds.Infrastructure.Messaging.AzureServiceBus;
 using ClassifiedAds.Infrastructure.Messaging.Kafka;
 using ClassifiedAds.Infrastructure.Messaging.RabbitMQ;
 
@@ -13,8 +12,6 @@ public class MessagingOptions
 
     public KafkaOptions Kafka { get; set; }
 
-    public AzureQueueOptions AzureQueue { get; set; }
-
     public AzureServiceBusOptions AzureServiceBus { get; set; }
 
     public bool UsedRabbitMQ()
@@ -27,11 +24,6 @@ public bool UsedKafka()
         return Provider == "Kafka";
     }
 
-    public bool UsedAzureQueue()
-    {
-        return Provider == "AzureQueue";
-    }
-
     public bool UsedAzureServiceBus()
     {
         return Provider == "AzureServiceBus";

src/Microservices/Common/ClassifiedAds.Infrastructure/Messaging/AzureQueue/AzureQueueSender.cs

@@ -16,7 +16,6 @@
     <PackageReference Include="Azure.Messaging.ServiceBus" Version="7.18.2" />
     <PackageReference Include="Azure.Monitor.OpenTelemetry.Exporter" Version="1.3.0" />
     <PackageReference Include="Azure.Storage.Blobs" Version="12.23.0" />
-    <PackageReference Include="Azure.Storage.Queues" Version="12.21.0" />
     <PackageReference Include="Castle.Core" Version="5.1.1" />
     <PackageReference Include="Confluent.Kafka" Version="2.8.0" />
     <PackageReference Include="CryptographyHelper" Version="3.1.0" />

src/Microservices/Common/ClassifiedAds.Infrastructure/Messaging/AzureQueue/AzureQueueStorageHealthCheck.cs

@@ -1,5 +1,4 @@
 using ClassifiedAds.Infrastructure.HealthChecks;
-using ClassifiedAds.Infrastructure.Messaging.AzureQueue;
 using ClassifiedAds.Infrastructure.Messaging.AzureServiceBus;
 using ClassifiedAds.Infrastructure.Messaging.Kafka;
 using ClassifiedAds.Infrastructure.Messaging.RabbitMQ;
@@ -79,25 +78,6 @@ public static IHealthChecksBuilder AddAzureBlobStorage(
             timeout));
     }
 
-    public static IHealthChecksBuilder AddAzureQueueStorage(
-        this IHealthChecksBuilder builder,
-        string connectionString,
-        string queueName,
-        string name = default,
-        HealthStatus? failureStatus = default,
-        IEnumerable<string> tags = default,
-        TimeSpan? timeout = default)
-    {
-        return builder.Add(new HealthCheckRegistration(
-            name,
-            new AzureQueueStorageHealthCheck(
-                connectionString: connectionString,
-                queueName: queueName),
-            failureStatus,
-            tags,
-            timeout));
-    }
-
     public static IHealthChecksBuilder AddAzureServiceBusQueue(
         this IHealthChecksBuilder builder,
         string connectionString,