bitwarden/server
1
0
Fork 0
mirror of https://github.com/bitwarden/server.git synced 2025-12-10 00:42:07 -06:00
Code Issues Packages Projects Releases 211 Wiki Activity

Add configurable queue name support to AzureQueueHostedService

Browse Source
This commit is contained in:
Brant DeBow 2025-12-09 19:12:05 -05:00
parent 6d5d7e58a6
commit 44decfdc25
No known key found for this signature in database
GPG Key ID: 94411BB25947C72B
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/EventsProcessor/AzureQueueHostedService.cs
View File

@ -57,14 +57,16 @@ public class AzureQueueHostedService : IHostedService, IDisposable
private async Task ExecuteAsync(CancellationToken cancellationToken) private async Task ExecuteAsync(CancellationToken cancellationToken)
{ {
var storageConnectionString = _configuration["azureStorageConnectionString"]; var storageConnectionString = _configuration["azureStorageConnectionString"];
if (string.IsNullOrWhiteSpace(storageConnectionString)) var queueName = _configuration["azureQueueServiceQueueName"];
if (string.IsNullOrWhiteSpace(storageConnectionString) ||
string.IsNullOrWhiteSpace(queueName))
{ {
return; return;
} }
var repo = new Core.Repositories.TableStorage.EventRepository(storageConnectionString); var repo = new Core.Repositories.TableStorage.EventRepository(storageConnectionString);
_eventWriteService = new RepositoryEventWriteService(repo); _eventWriteService = new RepositoryEventWriteService(repo);
_queueClient = new QueueClient(storageConnectionString, "event"); _queueClient = new QueueClient(storageConnectionString, queueName);
while (!cancellationToken.IsCancellationRequested) while (!cancellationToken.IsCancellationRequested)
{ {