Usando o Azure ServiceBus e a chamada OnMessage, estou procurando uma maneira de determinar se a bomba de eventos OnMessage interrompe a leitura da fila.

Nossa conexão com o OnMessage está configurada da seguinte forma:

protected virtual void DoSubscription(string queueName, Func<QueueRequest, bool> callback)
{
    var client = GetClient(queueName, PollingTimeout);
    var transformCallback = new Action<BrokeredMessage>((message) =>
    {
        try
        {
            var request = message.ToQueueRequest();
            if (callback(request))
            {
                message.Complete();
            }
            else
            {
                message.Abandon();
                Log.Warn("DoSubscription: Message Failed to Process Gracefully: {0}{1}", Environment.NewLine, JsonConvert.SerializeObject(request));
            }
        }
        catch (Exception ex)
        {
            Log.Error("DoSubscription: Message Failed to Process With Exception:", ex);
            message.Abandon();
        }
    });
    var options = new OnMessageOptions
    {
        MaxConcurrentCalls = _config.GetInt("MaxThreadsPerQueue"),
        AutoComplete = false,
        AutoRenewTimeout = new TimeSpan(0,0,1)
    };
    options.ExceptionReceived += OnMessageError;
    client.OnMessage(transformCallback, options);
}

O problema que estamos enfrentando ocorre após um período de tempo sem que as mensagens sejam enfileiradas. As novas mensagens enfileiradas não são capturadas pela bomba de eventos OnMessage até que o aplicativo seja reiniciado.

Sei que existem maneiras de fazer isso usando Funções de Trabalho, no entanto, para fins de monitoramento e gerenciamento, decidimos implementá-lo no Início do Aplicativo de um aplicativo Web.