optimized code

src/DotNetCore.CAP.MongoDB/ICapPublisher.MongoDB.cs

@@ -44,13 +44,5 @@ namespace DotNetCore.CAP.MongoDB
             var dbTrans = (IClientSessionHandle)transaction.DbTransaction;
             return collection.InsertOneAsync(dbTrans, message, insertOptions, cancel);
         }
-
-        //protected override object GetDbTransaction()
-        //{
-        //    var client = ServiceProvider.GetRequiredService<IMongoClient>();
-        //    var session = client.StartSession(new ClientSessionOptions());
-        //    session.StartTransaction();
-        //    return session;
-        //}
     }
 }
\ No newline at end of file

src/DotNetCore.CAP.MySql/ICapPublisher.MySql.cs

@@ -35,7 +35,6 @@ namespace DotNetCore.CAP.MySql
             {
                 using (var connection = new MySqlConnection(_options.ConnectionString))
                 {
-                    await connection.OpenAsync(cancel);
                     await connection.ExecuteAsync(PrepareSql(), message);
                     return;
                 }

src/DotNetCore.CAP.PostgreSql/ICapPublisher.PostgreSql.cs

@@ -19,7 +19,7 @@ namespace DotNetCore.CAP.PostgreSql
         private readonly PostgreSqlOptions _options;
         public PostgreSqlPublisher(IServiceProvider provider) : base(provider)
         {
-            _options = provider.GetService< PostgreSqlOptions>();
+            _options = provider.GetService<PostgreSqlOptions>();
         }
 
         public async Task PublishCallbackAsync(CapPublishedMessage message)
@@ -27,14 +27,15 @@ namespace DotNetCore.CAP.PostgreSql
             await PublishAsyncInternal(message);
         }
 
-        protected override Task ExecuteAsync(CapPublishedMessage message, ICapTransaction transaction,
+        protected override async Task ExecuteAsync(CapPublishedMessage message, ICapTransaction transaction,
             CancellationToken cancel = default(CancellationToken))
         {
             if (NotUseTransaction)
             {
                 using (var connection = InitDbConnection())
                 {
-                    return connection.ExecuteAsync(PrepareSql(), message);
+                    await connection.ExecuteAsync(PrepareSql(), message);
+                    return;
                 }
             }
 
@@ -44,7 +45,7 @@ namespace DotNetCore.CAP.PostgreSql
                 dbTrans = dbContextTrans.GetDbTransaction();
             }
             var conn = dbTrans?.Connection;
-            return conn.ExecuteAsync(PrepareSql(), message, dbTrans);
+            await conn.ExecuteAsync(PrepareSql(), message, dbTrans);
         }
 
         #region private methods

src/DotNetCore.CAP.SqlServer/ICapPublisher.SqlServer.cs

@@ -36,7 +36,6 @@ namespace DotNetCore.CAP.SqlServer
             {
                 using (var connection = new SqlConnection(_options.ConnectionString))
                 {
-                    await connection.OpenAsync(cancel);
                     await connection.ExecuteAsync(PrepareSql(), message);
                     return;
                 }