nhyatt/bitwarden
1
0
Fork 0
mirror of https://github.com/bitwarden/server.git synced 2025-05-22 12:04:27 -05:00
Code

catch any unhandled exceptions in event processor

Browse Source
This commit is contained in:
Kyle Spearrin 2019-07-11 15:43:20 -04:00
parent 242e509b9d
commit ba2c7fe67d
1 changed files with 15 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/EventsProcessor/AzureQueueHostedService.cs
View File

@ -71,18 +71,26 @@ namespace Bit.EventsProcessor
while(!cancellationToken.IsCancellationRequested) while(!cancellationToken.IsCancellationRequested)
{ {
var messages = await _queue.GetMessagesAsync(32, TimeSpan.FromMinutes(1), try
null, null, cancellationToken);
if(messages.Any())
{ {
foreach(var message in messages) var messages = await _queue.GetMessagesAsync(32, TimeSpan.FromMinutes(1),
null, null, cancellationToken);
if(messages.Any())
{ {
await ProcessQueueMessageAsync(message.AsString, cancellationToken); foreach(var message in messages)
await _queue.DeleteMessageAsync(message); {
await ProcessQueueMessageAsync(message.AsString, cancellationToken);
await _queue.DeleteMessageAsync(message);
}
}
else
{
await Task.Delay(TimeSpan.FromSeconds(5), cancellationToken);
} }
} }
else catch(Exception e)
{ {
_logger.LogError(e, "Exception occurred: " + e.Message);
await Task.Delay(TimeSpan.FromSeconds(5), cancellationToken); await Task.Delay(TimeSpan.FromSeconds(5), cancellationToken);
} }
} }
@ -124,11 +132,6 @@ namespace Bit.EventsProcessor
{ {
_logger.LogError("JsonSerializationException: Unable to serialize token."); _logger.LogError("JsonSerializationException: Unable to serialize token.");
} }
catch(Exception e)
{
_logger.LogError(e, "Exception occurred. " + e.Message);
throw e;
}
} }
} }
} }