diff --git a/src/DotNetCore.CAP/Abstractions/CapPublisherBase.cs b/src/DotNetCore.CAP/Abstractions/CapPublisherBase.cs
index f821824..37e9808 100644
--- a/src/DotNetCore.CAP/Abstractions/CapPublisherBase.cs
+++ b/src/DotNetCore.CAP/Abstractions/CapPublisherBase.cs
@@ -123,7 +123,7 @@ namespace DotNetCore.CAP.Abstractions
                     "If you are using the EntityFramework, you do not need to use this overloaded.");
         }
 
-        private Task PublishWithTransAsync(string name, string content)
+        private async Task PublishWithTransAsync(string name, string content)
         {
             var message = new CapPublishedMessage
             {
@@ -132,13 +132,11 @@ namespace DotNetCore.CAP.Abstractions
                 StatusName = StatusName.Scheduled
             };
 
-            ExecuteAsync(DbConnection, DbTransaction, message);
+            await ExecuteAsync(DbConnection, DbTransaction, message);
 
             ClosedCap();
 
             PublishQueuer.PulseEvent.Set();
-
-            return Task.CompletedTask;
         }
 
         private void PublishWithTrans(string name, string content)