移除舊版ServiceBus SDK與代碼

TEAMModelOS.SDK/DI/AzureServiceBus/AzureServiceBusFactory.cs

@@ -43,21 +43,6 @@ namespace TEAMModelOS.SDK.DI
                 _logger?.LogWarning(e, e.Message);
                 return null;
             }
-        }
-
-        public TopicClient GetTopicClient(ReceiveMode receiveMode, string name = "Default")
-        {
-            try
-            {
-                ServiceBusConnectionStringBuilder builder = new ServiceBusConnectionStringBuilder(_optionsMonitor.Get(name).ServiceBusConnectionString);
-                TopicClient client = new TopicClient(builder, receiveMode);
-                return client;
-            }
-            catch (OptionsValidationException e)
-            {
-                _logger?.LogWarning(e, e.Message);
-                return null;
-            }
-        }
+        }       
     }
 }

TEAMModelOS.SDK/Module/AzureServiceBus/AzureServiceBusClientSingleton.cs

@@ -1,74 +0,0 @@
-using Microsoft.Azure.ServiceBus;
-using System;
-using System.Collections.Generic;
-using System.Text;
-
-namespace TEAMModelOS.SDK.Module.AzureServiceBus
-{
-    public  class AzureServiceBusClientSingleton
-    {
-
-        private ServiceBusModel ServiceBusModel;
-        public static AzureServiceBusOptions azureServiceBusOptions;
-        private AzureServiceBusClientSingleton() { }
-        public ServiceBusModel GetServiceBusClient()
-        {
-            if (ServiceBusModel != null)
-            {
-                return ServiceBusModel;
-            }
-            else
-            {
-                getInstance(azureServiceBusOptions);
-                return ServiceBusModel;
-            }
-        }
-        public static AzureServiceBusClientSingleton getInstance(AzureServiceBusOptions _azureServiceBusOptions)
-        {
-            azureServiceBusOptions= _azureServiceBusOptions;
-          
-         
-            return SingletonInstance.instance;
-        }
-
-        private static class SingletonInstance
-        {
-            public static AzureServiceBusClientSingleton instance = new AzureServiceBusClientSingleton()
-            {
-                ServiceBusModel = new ServiceBusModel { topClients = GetTopClients(),subClients=GetSubClients() }
-            };
-        }
-
-        private static Dictionary<string, TopClient> GetTopClients() {
-            Dictionary<string, TopClient> topClients = new Dictionary<string, TopClient>();
-            string ConnectionString = azureServiceBusOptions.ConnectionString;
-            azureServiceBusOptions.Topics.ForEach(x=> { topClients.TryAdd(x.Name, new TopClient { topicClient = new TopicClient(ConnectionString, x.Name) }); });
-            return topClients;
-        }
-        private static Dictionary<string, SubClient> GetSubClients()
-        {
-            Dictionary<string, SubClient>  subClients = new Dictionary<string, SubClient>();
-            string ConnectionString = azureServiceBusOptions.ConnectionString;
-            azureServiceBusOptions.Topics.ForEach(x => { x.Subscribe.ForEach(y => { subClients.TryAdd(y, new SubClient { topName = x.Name, subscriptionClient = new SubscriptionClient(ConnectionString, x.Name, y) }); }); });
-            return subClients;
-        }
-    }
-
-
-    public class ServiceBusModel {
-       public Dictionary<string, TopClient> topClients { get; set; } = new Dictionary<string, TopClient>();
-        public Dictionary<string, SubClient> subClients { get; set; } = new Dictionary<string, SubClient>();
-       
-    }
-
-    public class TopClient { 
-       
-        public ITopicClient topicClient { get; set; }
-    }
-    public class SubClient
-    {
-        public string topName { get; set; }
-       
-        public ISubscriptionClient subscriptionClient { get; set; }
-    }
-}

TEAMModelOS.SDK/Module/AzureServiceBus/AzureServiceBusCollectionExtensions.cs

@@ -1,39 +0,0 @@
-using Microsoft.Extensions.DependencyInjection;
-using System;
-using System.Collections.Generic;
-using System.Text;
-using TEAMModelOS.SDK.Module.AzureServiceBus;
-
-namespace TEAMModelOS.SDK
-{
-    public static class AzureServiceBusCollectionExtensions
-    {
-
-        private static AzureServiceBusServiceBuilder AddServiceBusBuilder(this IServiceCollection services)
-        {
-            return new AzureServiceBusServiceBuilder(services);
-        }
-        /// <summary>
-        /// 
-        /// </summary>
-        /// <param name="services"></param>
-        /// <returns></returns>
-        public static AzureServiceBusServiceBuilder AddServiceBus(this IServiceCollection services)
-        {
-            var builder = services.AddServiceBusBuilder();
-            services.AddSingleton<IAzureServiceBusService, AzureServiceBusService>();
-            return builder;
-        }
-        /// <summary>
-        /// 
-        /// </summary>
-        /// <param name="builder"></param>
-        /// <param name="_connectionString"></param>
-        /// <returns></returns>
-        public static AzureServiceBusServiceBuilder AddServiceBusOptions(this AzureServiceBusServiceBuilder builder, AzureServiceBusOptions serviceBusOptions)
-        {
-            builder.Services.AddSingleton(serviceBusOptions);
-            return builder;
-        }
-    }
-}

TEAMModelOS.SDK/Module/AzureServiceBus/AzureServiceBusOptions.cs

@@ -1,29 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Text;
-
-namespace TEAMModelOS.SDK.Module.AzureServiceBus
-{
-    /// <summary>
-    /// 主题配置信息
-    /// </summary>
-    public  class AzureServiceBusOptions
-    {
-        public string ConnectionString { get; set; } = null;
-        public List<Topic> Topics { get; set; } = null;
-       
-    }
-    /// <summary>
-    /// 主题
-    /// </summary>
-    public class Topic { 
-        /// <summary>
-        /// 主题名称
-        /// </summary>
-        public string Name { get; set; }
-        /// <summary>
-        /// 主题的订阅器
-        /// </summary>
-        public List<string> Subscribe { get; set; }
-    }
-}

TEAMModelOS.SDK/Module/AzureServiceBus/AzureServiceBusService.cs

@@ -1,32 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Text;
-
-namespace TEAMModelOS.SDK.Module.AzureServiceBus
-{
-    public class AzureServiceBusService :IAzureServiceBusService
-    {
-        public ServiceBusModel serviceBusModel;
-
-        public AzureServiceBusService(AzureServiceBusOptions options) {
-            serviceBusModel = AzureServiceBusClientSingleton.getInstance(options).GetServiceBusClient() ;
-        }
-
-
-        public void init() {
-            if (serviceBusModel != null) {
-                
-            }
-        }
-        public TopClient GetTopClient(string TopName) {
-            serviceBusModel.topClients.TryGetValue(TopName, out TopClient topClient);
-            return topClient;
-        }
-
-        public SubClient GetSubClient(string SubName)
-        {
-            serviceBusModel.subClients.TryGetValue(SubName, out SubClient subClient);
-            return subClient;
-        }
-    }
-}

TEAMModelOS.SDK/Module/AzureServiceBus/AzureServiceBusServiceBuilder.cs

@@ -1,24 +0,0 @@
-using Microsoft.Extensions.DependencyInjection;
-using System;
-using System.Collections.Generic;
-using System.Text;
-
-namespace TEAMModelOS.SDK.Module.AzureServiceBus
-{
-    public class AzureServiceBusServiceBuilder
-    {
-        /// <summary>
-        /// 
-        /// </summary>
-        /// <param name="services"></param>
-        public AzureServiceBusServiceBuilder(IServiceCollection services)
-        {
-            Services = services ?? throw new ArgumentNullException(nameof(services));
-        }
-
-        /// <summary>
-        /// 
-        /// </summary>
-        public IServiceCollection Services { get; }
-    }
-}

TEAMModelOS.SDK/Module/AzureServiceBus/IAzureServiceBusService.cs

@@ -1,13 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Text;
-
-namespace TEAMModelOS.SDK.Module.AzureServiceBus
-{
-    public interface IAzureServiceBusService
-    {
-        public TopClient GetTopClient(string TopName);
-        public SubClient GetSubClient(string SubName);
-        void init();
-    }
-}