mirror of
https://github.com/bitwarden/server.git
synced 2025-04-26 23:32:19 -05:00
21 lines
729 B
C#
21 lines
729 B
C#
using Azure.Storage.Queues;
|
|
using Bit.Core.Models.Mail;
|
|
using Bit.Core.Settings;
|
|
using Bit.Core.Utilities;
|
|
|
|
namespace Bit.Core.Services;
|
|
|
|
public class AzureQueueMailService : AzureQueueService<IMailQueueMessage>, IMailEnqueuingService
|
|
{
|
|
public AzureQueueMailService(GlobalSettings globalSettings) : base(
|
|
new QueueClient(globalSettings.Mail.ConnectionString, "mail"),
|
|
JsonHelpers.IgnoreWritingNull)
|
|
{ }
|
|
|
|
public Task EnqueueAsync(IMailQueueMessage message, Func<IMailQueueMessage, Task> fallback) =>
|
|
CreateManyAsync(new[] { message });
|
|
|
|
public Task EnqueueManyAsync(IEnumerable<IMailQueueMessage> messages, Func<IMailQueueMessage, Task> fallback) =>
|
|
CreateManyAsync(messages);
|
|
}
|