From eb7fa083356f10c5f251379093b90d3fb92bba5d Mon Sep 17 00:00:00 2001
From: William Obando <william@oban.do>
Date: Thu, 10 Mar 2022 22:49:14 -0500
Subject: [PATCH] Add option to disable service bus

---
 .../Abp/EventBus/Azure/AbpAzureEventBusOptions.cs |  2 ++
 .../Abp/EventBus/Azure/AbpEventBusAzureModule.cs  | 15 +++++++++++----
 2 files changed, 13 insertions(+), 4 deletions(-)

diff --git a/framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AbpAzureEventBusOptions.cs b/framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AbpAzureEventBusOptions.cs
index a6aa2f9857..57fa4b7f48 100644
--- a/framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AbpAzureEventBusOptions.cs
+++ b/framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AbpAzureEventBusOptions.cs
@@ -7,4 +7,6 @@ public class AbpAzureEventBusOptions
     public string SubscriberName { get; set; }
 
     public string TopicName { get; set; }
+
+    public bool IsServiceBusDisabled { get; set; }
 }
diff --git a/framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AbpEventBusAzureModule.cs b/framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AbpEventBusAzureModule.cs
index 64c8b2fcd3..129004c871 100644
--- a/framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AbpEventBusAzureModule.cs
+++ b/framework/src/Volo.Abp.EventBus.Azure/Volo/Abp/EventBus/Azure/AbpEventBusAzureModule.cs
@@ -1,4 +1,5 @@
 using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Options;
 using Volo.Abp.AzureServiceBus;
 using Volo.Abp.Modularity;
 
@@ -19,9 +20,15 @@ public class AbpEventBusAzureModule : AbpModule
 
     public override void OnApplicationInitialization(ApplicationInitializationContext context)
     {
-        context
-            .ServiceProvider
-            .GetRequiredService<AzureDistributedEventBus>()
-            .Initialize();
+        var options = context.ServiceProvider.GetRequiredService<IOptions<AbpAzureEventBusOptions>>().Value;
+
+        if (!options.IsServiceBusDisabled)
+        {
+            context
+                .ServiceProvider
+                .GetRequiredService<AzureDistributedEventBus>()
+                .Initialize();
+        }
+
     }
 }