fixed thread conflict issue when sending messages with PublishAsync. #80

Author: yang-xiaodong

src/DotNetCore.CAP.MySql/CapPublisher.cs

@@ -62,14 +62,12 @@ protected override void Execute(IDbConnection dbConnection, IDbTransaction dbTra
             _logger.LogInformation("Published Message has been persisted in the database. name:" + message);
         }
 
-        protected override Task ExecuteAsync(IDbConnection dbConnection, IDbTransaction dbTransaction,
+        protected override async Task ExecuteAsync(IDbConnection dbConnection, IDbTransaction dbTransaction,
             CapPublishedMessage message)
         {
-            dbConnection.ExecuteAsync(PrepareSql(), message, dbTransaction);
+            await dbConnection.ExecuteAsync(PrepareSql(), message, dbTransaction);
 
             _logger.LogInformation("Published Message has been persisted in the database. name:" + message);
-
-            return Task.CompletedTask;
         }
 
         #region private methods

src/DotNetCore.CAP.PostgreSql/CapPublisher.cs

@@ -64,14 +64,12 @@ protected override void Execute(IDbConnection dbConnection, IDbTransaction dbTra
             _logger.LogInformation("Published Message has been persisted in the database. name:" + message);
         }
 
-        protected override Task ExecuteAsync(IDbConnection dbConnection, IDbTransaction dbTransaction,
+        protected override async Task ExecuteAsync(IDbConnection dbConnection, IDbTransaction dbTransaction,
             CapPublishedMessage message)
         {
-            dbConnection.ExecuteAsync(PrepareSql(), message, dbTransaction);
+            await dbConnection.ExecuteAsync(PrepareSql(), message, dbTransaction);
 
             _logger.LogInformation("Published Message has been persisted in the database. name:" + message);
-
-            return Task.CompletedTask;
         }
 
         #region private methods

src/DotNetCore.CAP.SqlServer/CapPublisher.cs

@@ -63,14 +63,12 @@ protected override void Execute(IDbConnection dbConnection, IDbTransaction dbTra
             _logger.LogInformation("published message has been persisted to the database. name:" + message);
         }
 
-        protected override Task ExecuteAsync(IDbConnection dbConnection, IDbTransaction dbTransaction,
+        protected override async Task ExecuteAsync(IDbConnection dbConnection, IDbTransaction dbTransaction,
             CapPublishedMessage message)
         {
-            dbConnection.ExecuteAsync(PrepareSql(), message, dbTransaction);
+            await dbConnection.ExecuteAsync(PrepareSql(), message, dbTransaction);
 
             _logger.LogInformation("published message has been persisted to the database. name:" + message);
-
-            return Task.CompletedTask;
         }
 
         #region private methods