Merge pull request #81 from wemogy/feature/configureServiceBusProcess…

…orOptions Added configureServiceBusProcessorOptions support
wemogy · Feb 17, 2024 · 778edd6 · 778edd6
2 parents c11cb05 + e156e13
commit 778edd6
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/...erviceBus/Wemogy.CQRS.Extensions.AzureServiceBus/Setup/AzureServiceBusSetupEnvironment.cs b/...erviceBus/Wemogy.CQRS.Extensions.AzureServiceBus/Setup/AzureServiceBusSetupEnvironment.cs
@@ -30,17 +30,22 @@ public AzureServiceBusSetupEnvironment(ServiceBusClient serviceBusClient, IServi
         /// Creates a ServiceBusProcessor and subscribes to messages of type <typeparamref name="TCommand"/>
         /// </summary>
         public AzureServiceBusSetupEnvironment AddDelayedProcessor<TCommand>(
-            int maxConcurrentCalls = 1)
+            int maxConcurrentCalls = 1,
+            Action<ServiceBusProcessorOptions>? configureServiceBusProcessorOptions = null)
             where TCommand : ICommandBase
         {
             var queueName = GetQueueName<TCommand>();
 
             _serviceCollection.AddHostedService<IDelayedCommandProcessorHostedService<TCommand>>(_ =>
             {
-                var serviceBusProcessor = _serviceBusClient.CreateProcessor(queueName, new ServiceBusProcessorOptions()
+                var serviceBusProcessorOptions = new ServiceBusProcessorOptions()
                 {
                     MaxConcurrentCalls = maxConcurrentCalls
-                });
+                };
+
+                configureServiceBusProcessorOptions?.Invoke(serviceBusProcessorOptions);
+
+                var serviceBusProcessor = _serviceBusClient.CreateProcessor(queueName, serviceBusProcessorOptions);
                 var processor = new AzureServiceBusCommandProcessor<TCommand>(serviceBusProcessor, _serviceCollection);
 
                 return processor;