Azure Service Bus, определите, останавливает ли OnMessage обработку
Используя Azure ServiceBus и вызов OnMessage, я ищу способ определить, прекращает ли насос событий OnMessage чтение из очереди.
Наше соединение с OnMessage настроено следующим образом:
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);
}
Проблема, с которой мы сталкиваемся, заключается в том, что по истечении определенного периода времени, когда в очереди нет сообщений, новые сообщения, находящиеся в очереди, не могут быть получены насосом событий OnMessage до тех пор, пока приложение не будет перезапущено.
Я понимаю, что есть способы сделать это с помощью рабочих ролей, однако для целей мониторинга и управления мы решили реализовать это при запуске приложения веб-приложения.