From e21cdd13d9f36636f6fd0cfe7cd78d4a1363b424 Mon Sep 17 00:00:00 2001 From: Savorboard Date: Mon, 27 Nov 2017 16:45:59 +0800 Subject: [PATCH] rename methods --- src/DotNetCore.CAP/IQueueExecutor.Subscribe.cs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/DotNetCore.CAP/IQueueExecutor.Subscribe.cs b/src/DotNetCore.CAP/IQueueExecutor.Subscribe.cs index 9322026..7435b4b 100644 --- a/src/DotNetCore.CAP/IQueueExecutor.Subscribe.cs +++ b/src/DotNetCore.CAP/IQueueExecutor.Subscribe.cs @@ -76,7 +76,7 @@ namespace DotNetCore.CAP } catch (Exception ex) { - _logger.ExceptionOccuredWhileExecuting(message?.Name, ex); + _logger.ExceptionOccuredWhileExecuting(message.Name, ex); fetched.Requeue(); @@ -89,7 +89,7 @@ namespace DotNetCore.CAP IState newState; if (!result.Succeeded) { - var shouldRetry = UpdateMessageForRetryAsync(message); + var shouldRetry = UpdateMessageForRetry(message); if (shouldRetry) { newState = new ScheduledState(); @@ -109,7 +109,7 @@ namespace DotNetCore.CAP return newState; } - private static bool UpdateMessageForRetryAsync(CapReceivedMessage message) + private static bool UpdateMessageForRetry(CapReceivedMessage message) { var retryBehavior = RetryBehavior.DefaultRetry;