diff --git a/src/DotNetCore.CAP/IPublishMessageSender.Base.cs b/src/DotNetCore.CAP/IPublishMessageSender.Base.cs
index a597169..a64a6a7 100644
--- a/src/DotNetCore.CAP/IPublishMessageSender.Base.cs
+++ b/src/DotNetCore.CAP/IPublishMessageSender.Base.cs
@@ -75,7 +75,7 @@ namespace DotNetCore.CAP
                 {
                     _logger.SenderRetrying(message.Id, message.Retries);
 
-                    await SendAsync(message);
+                    return await SendAsync(message);
                 }
                 return OperateResult.Failed(result.Exception);
             }
diff --git a/src/DotNetCore.CAP/ISubscribeExecutor.Default.cs b/src/DotNetCore.CAP/ISubscribeExecutor.Default.cs
index fe03a15..d069d95 100644
--- a/src/DotNetCore.CAP/ISubscribeExecutor.Default.cs
+++ b/src/DotNetCore.CAP/ISubscribeExecutor.Default.cs
@@ -77,7 +77,7 @@ namespace DotNetCore.CAP
                 await SetFailedState(message, ex, out bool stillRetry);
                 if (stillRetry)
                 {
-                    await ExecuteAsync(message);
+                   return await ExecuteAsync(message);
                 }
 
                 return OperateResult.Failed(ex);