Commit 4fe8259c authored by Savorboard's avatar Savorboard

Fixed SendAsync or ExecuteAsync recursion retries bug. (#160)

parent 2c743162
...@@ -75,7 +75,7 @@ namespace DotNetCore.CAP ...@@ -75,7 +75,7 @@ namespace DotNetCore.CAP
{ {
_logger.SenderRetrying(message.Id, message.Retries); _logger.SenderRetrying(message.Id, message.Retries);
await SendAsync(message); return await SendAsync(message);
} }
return OperateResult.Failed(result.Exception); return OperateResult.Failed(result.Exception);
} }
......
...@@ -77,7 +77,7 @@ namespace DotNetCore.CAP ...@@ -77,7 +77,7 @@ namespace DotNetCore.CAP
await SetFailedState(message, ex, out bool stillRetry); await SetFailedState(message, ex, out bool stillRetry);
if (stillRetry) if (stillRetry)
{ {
await ExecuteAsync(message); return await ExecuteAsync(message);
} }
return OperateResult.Failed(ex); return OperateResult.Failed(ex);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment