refactor.

src/DotNetCore.CAP.MySql/CAP.MySqlCapOptionsExtension.cs

@@ -20,9 +20,9 @@ namespace DotNetCore.CAP
         {
             services.AddSingleton<CapDatabaseStorageMarkerService>();
             services.AddSingleton<IStorage, MySqlStorage>();
-            services.AddScoped<IStorageConnection, MySqlStorageConnection>();
+            services.AddSingleton<IStorageConnection, MySqlStorageConnection>();
             services.AddScoped<ICapPublisher, CapPublisher>();
-            services.AddTransient<ICallbackPublisher, CapPublisher>();
+            services.AddScoped<ICallbackPublisher, CapPublisher>();
             services.AddTransient<IAdditionalProcessor, DefaultAdditionalProcessor>();
 
             var mysqlOptions = new MySqlOptions();

src/DotNetCore.CAP.PostgreSql/CAP.PostgreSqlCapOptionsExtension.cs

@@ -20,9 +20,9 @@ namespace DotNetCore.CAP
         {
             services.AddSingleton<CapDatabaseStorageMarkerService>();
             services.AddSingleton<IStorage, PostgreSqlStorage>();
-            services.AddScoped<IStorageConnection, PostgreSqlStorageConnection>();
+            services.AddSingleton<IStorageConnection, PostgreSqlStorageConnection>();
             services.AddScoped<ICapPublisher, CapPublisher>();
-            services.AddTransient<ICallbackPublisher, CapPublisher>();
+            services.AddScoped<ICallbackPublisher, CapPublisher>();
             services.AddTransient<IAdditionalProcessor, DefaultAdditionalProcessor>();
 
             var postgreSqlOptions = new PostgreSqlOptions();

src/DotNetCore.CAP.PostgreSql/PostgreSqlStorageConnection.cs

@@ -13,7 +13,7 @@ namespace DotNetCore.CAP.PostgreSql
     {
         private readonly CapOptions _capOptions;
 
-        public PostgreSqlStorageConnection(PostgreSqlOptions options,CapOptions capOptions)
+        public PostgreSqlStorageConnection(PostgreSqlOptions options, CapOptions capOptions)
         {
             _capOptions = capOptions;
             Options = options;

src/DotNetCore.CAP.SqlServer/CAP.SqlServerCapOptionsExtension.cs

@@ -21,8 +21,8 @@ namespace DotNetCore.CAP
             services.AddSingleton<CapDatabaseStorageMarkerService>();
             services.AddSingleton<IStorage, SqlServerStorage>();
             services.AddSingleton<IStorageConnection, SqlServerStorageConnection>();
-            services.AddTransient<ICapPublisher, CapPublisher>();
-            services.AddTransient<ICallbackPublisher, CapPublisher>();
+            services.AddScoped<ICapPublisher, CapPublisher>();
+            services.AddScoped<ICallbackPublisher, CapPublisher>();
             services.AddTransient<IAdditionalProcessor, DefaultAdditionalProcessor>();
             AddSqlServerOptions(services);
         }