Add support for prefixing queue names

This commit is contained in:
Sipke Schoorstra 2021-01-14 14:56:09 +01:00
parent 02a3df468c
commit 6b380e86f4
2 changed files with 4 additions and 1 deletions

View file

@ -6,6 +6,7 @@ namespace Elsa
{
public int? NumberOfWorkers { get; set; }
public int? MaxParallelism { get; set; }
public string? QueuePrefix { get; set; }
public void Apply(OptionsConfigurer configurer)
{

View file

@ -25,7 +25,7 @@ namespace Elsa.Services
public async Task<IBus> GetServiceBusAsync(Type messageType, CancellationToken cancellationToken)
{
var queueName = messageType.Name;
var queueName = FormatQueueName(messageType.Name);
await _semaphore.WaitAsync(cancellationToken);
try
@ -49,5 +49,7 @@ namespace Elsa.Services
_semaphore.Release();
}
}
private string FormatQueueName(string name) => $"{_elsaOptions.ServiceBusOptions.QueuePrefix}{name}";
}
}