Browse Source

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

undefined
Savorboard 6 years ago
parent
commit
f0bd253c92
2 changed files with 2 additions and 2 deletions
  1. +1
    -1
      src/DotNetCore.CAP/IPublishMessageSender.Base.cs
  2. +1
    -1
      src/DotNetCore.CAP/ISubscribeExecutor.Default.cs

+ 1
- 1
src/DotNetCore.CAP/IPublishMessageSender.Base.cs View File

@@ -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);
} }


+ 1
- 1
src/DotNetCore.CAP/ISubscribeExecutor.Default.cs View File

@@ -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);


Loading…
Cancel
Save