Upstream/bitwarden-server
1
0
Fork 0
mirror of https://github.com/bitwarden/server.git synced 2025-01-16 20:51:23 +01:00
Code Issues Projects Releases Wiki Activity

some logging from queue service

Browse Source
This commit is contained in:
Kyle Spearrin 2018-08-24 11:23:39 -04:00
parent 53caacb870
commit 263dfda9c4
1 changed files with 23 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
src/Notifications/AzureQueueHostedService.cs
View File

@ -60,26 +60,34 @@ namespace Bit.Notifications
var queueClient = storageAccount.CreateCloudQueueClient();
_queue = queueClient.GetQueueReference("notifications");
while(!cancellationToken.IsCancellationRequested)
_logger.LogInformation("starting queue read");
try
{
var messages = await _queue.GetMessagesAsync(32, TimeSpan.FromMinutes(1),
null, null, cancellationToken);
if(messages.Any())
while(!cancellationToken.IsCancellationRequested)
{
foreach(var message in messages)
var messages = await _queue.GetMessagesAsync(32, TimeSpan.FromMinutes(1),
null, null, cancellationToken);
if(messages.Any())
{
var notificationJson = message.AsString;
var notification = JsonConvert.DeserializeObject<PushNotificationData<object>>(
notificationJson);
await HubHelpers.SendNotificationToHubAsync(notification.Type, notificationJson,
_hubContext, cancellationToken);
await _queue.DeleteMessageAsync(message);
foreach(var message in messages)
{
var notificationJson = message.AsString;
var notification = JsonConvert.DeserializeObject<PushNotificationData<object>>(
notificationJson);
await HubHelpers.SendNotificationToHubAsync(notification.Type, notificationJson,
_hubContext, cancellationToken);
await _queue.DeleteMessageAsync(message);
}
}
else
{
await Task.Delay(TimeSpan.FromSeconds(5), cancellationToken);
}
}
else
{
await Task.Delay(TimeSpan.FromSeconds(5), cancellationToken);
}
}
catch(Exception e)
{
_logger.LogError(e, "error from queue");
}
}
}