اضافه کردن قابلیت پردازش دوباره پیام به Rabbitmq

_consumer.Received += (model, result) =>
{
    try
    {
        var message = Encoding.UTF8.GetString(result.Body.ToArray());

        // Do some work on message
        var isSuccessful = Received.Invoke(message);

        if (isSuccessful)
        {
            counter = 0;

            _channel.BasicAck(result.DeliveryTag, false);

            return;
        }

        if (counter > config.RequeueMessageRetryCount)
        {
            counter = 0;

            // Requeue = false is important
            _channel.BasicReject(result.DeliveryTag, false);

            return;
        }
    }
    catch (Exception ex)
    {
        LogError(ex);
    }

    counter++;

    // Prevent Very fast failed message process
    Thread.Sleep(WaitInNackOnMilliSecond);

     // Requeue = true is important to reprocess
    _channel.BasicNack(result.DeliveryTag, false, true);
};

_channel.BasicConsume(config.Queue, false, _consumer);

_consumer.Received += (model, result) =>
{
    try
    {
        var message = Encoding.UTF8.GetString(result.Body.ToArray());

        while (counter < config.RequeueMessageRetryCount)
        {
            var isSuccess = false;

            try
            {
                isSuccess = Received.Invoke(message);
            }
            catch (Exception)
            {
                // ignored
            }

            if (isSuccess)
            {
                counter = 0;

                _channel.BasicAck(result.DeliveryTag, false);

                return;
            }

            counter++;

            Thread.Sleep(WaitInReprocessOnMilliSecond);
        }

        counter = 0;

        _channel.BasicReject(result.DeliveryTag, false);
    }
    catch (Exception ex)
    {
        ExceptionOccured(ex);
    }
};

_channel.BasicConsume(config.Queue, false, _consumer);