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;