Azure Очередь хранения не отправляет сообщение очереди

Question

Я использую хранилище очереди в лазурном порядке для отправки электронной почты. Письма хранятся в хранилище очередей, и очередь отправляет по 20 писем за раз.

//Checks for messages inn the queue 
foreach (CloudQueueMessage msgin sendEmailQueue.GetMessages(20, TimeSpan.FromSeconds(50))) 
    { 
     ProcessQueueMessage(msg); 

    } 

Проблема, которую я имею что когда электронную почту добавляются в очередь с некорректными реквизитами SMTP (т.е. неверного пароль), сообщение остается в очереди, поскольку не может отправлять и предотвращает другие сообщения в очереди от отправки.

private void ProcessQueueMessage(CloudQueueMessage msg) 
{ 
    try 
    { 
    //We try to send an email 
    SendEmail(emailRowInMessageTable, htmlMessageBodyRef, textMessageBodyRef); 

    } catch (SmtpException e) 
    { 
    string err = e.Message; 

    //When an error occurs we check to see if the message failed to send certain no. of  
     times 
    if (msg.DequeueCount > 10) 
    { 
     //We delete the message from queue 
     sendEmailQueue.DeleteMessage(msg); 

     return; 
    } else 
    { 
     //delete from top of queue 
     sendEmailQueue.DeleteMessage(msg); 

     //insert into end of queue 
     sendEmailQueue.AddMessage(msg); 

     return; 
    } 
    } 
} 

Решение, которое я попытался было удалить сообщение из очереди, если произошла ошибка, и добавить его обратно в конец очереди, в результате правильных писем, являющихся разослать. Но удаление и добавление сообщение обратно в очередь сбрасывает свойство dequeue, которое не является идеальным , так как я использую свойство dequeue, чтобы убедиться, что сообщение не находится в очереди навсегда.

Что было бы лучшим решением в этой ситуации?

Answer 1

Решение должно было использовать разные очереди для разных SMTP-серверов и запускать все из одной рабочей роли с использованием нескольких потоков.

Используется здесь: http://www.31a2ba2a-b718-11dc-8314-0800200c9a66.com/2010/12/running-multiple-threads-on-windows.html для запуска нескольких потоков внутри одной рабочей роли.

Answer 2

Вам действительно не нужно удалять сообщение и добавлять его. Когда срок действия сообщения visibility timeout (50 секунд в вашем случае) истек, он автоматически появится в очереди. Таким образом, ваша логика DequeueCount также будет работать так же, как одно и то же сообщение будет удалено и снова выставлено в очередь.

Обратите внимание, что очереди Windows Azure являются наилучшим усилием FIFO ... поэтому это не всегда необходимо и сообщения будут выбраны исходя из того, что они были добавлены. Вы можете сделать несколько вещей:

• Сократить число повторных попыток (в настоящее время у вас есть 10, вы можете уменьшить его до 5) или
• Проверки на фактическое исключение. Если процесс завершился неудачно из-за неправильных учетных данных, он не будет работать в следующий раз и в следующий раз после этого. Нет смысла повторять это сообщение. Вы можете просто перенести это сообщение в ядовитую очередь, чтобы позже вы могли проверить это сообщение.