diff --git a/NsqSharp/Bus/MessageDistributor.cs b/NsqSharp/Bus/MessageDistributor.cs index 921f23e..2619ce6 100644 --- a/NsqSharp/Bus/MessageDistributor.cs +++ b/NsqSharp/Bus/MessageDistributor.cs @@ -162,7 +162,7 @@ public void HandleMessage(IMessage message) ( messageInformation, requeue ? FailedMessageQueueAction.Requeue : FailedMessageQueueAction.Finish, - FailedMessageReason.HandlerException, + requeue ? FailedMessageReason.HandlerException : FailedMessageReason.MaxAttemptsExceeded, ex ) );