Disable queueing work if queue is disabled for RedisQueueProvider (PR danielgerlag#1154 )

Author: Tolstovku

src/providers/WorkflowCore.Providers.Redis/ServiceCollectionExtensions.cs

@@ -9,7 +9,7 @@ public static class ServiceCollectionExtensions
     {
         public static WorkflowOptions UseRedisQueues(this WorkflowOptions options, string connectionString, string prefix)
         {
-            options.UseQueueProvider(sp => new RedisQueueProvider(connectionString, prefix, sp.GetService<ILoggerFactory>()));
+            options.UseQueueProvider(sp => new RedisQueueProvider(connectionString, prefix, sp.GetService<WorkflowOptions>(), sp.GetService<ILoggerFactory>()));
             return options;
         }
 

src/providers/WorkflowCore.Providers.Redis/Services/RedisQueueProvider.cs

@@ -5,6 +5,7 @@
 using Microsoft.Extensions.Logging;
 using StackExchange.Redis;
 using WorkflowCore.Interface;
+using WorkflowCore.Models;
 
 namespace WorkflowCore.Providers.Redis.Services
 {
@@ -24,15 +25,25 @@ public class RedisQueueProvider : IQueueProvider
             [QueueType.Index] = "index"
         };
 
-        public RedisQueueProvider(string connectionString, string prefix, ILoggerFactory logFactory)
+        private readonly Dictionary<QueueType, bool> _enabledQueues = new Dictionary<QueueType, bool>();
+
+        public RedisQueueProvider(string connectionString, string prefix, WorkflowOptions options, ILoggerFactory logFactory)
         {
             _connectionString = connectionString;
             _prefix = prefix;
+            _enabledQueues[QueueType.Index] = options.EnableIndexes;
+            _enabledQueues[QueueType.Event] = options.EnableEvents;
+            _enabledQueues[QueueType.Workflow] = options.EnableWorkflows;
             _logger = logFactory.CreateLogger(GetType());
         }
 
         public async Task QueueWork(string id, QueueType queue)
         {
+            if (!_enabledQueues[queue])
+            {
+                return;
+            }
+
             if (_redis == null)
                 throw new InvalidOperationException();
 
@@ -47,6 +58,11 @@ public async Task QueueWork(string id, QueueType queue)
 
         public async Task<string> DequeueWork(QueueType queue, CancellationToken cancellationToken)
         {
+            if (!_enabledQueues[queue])
+            {
+                return null;
+            }
+
             if (_redis == null)
                 throw new InvalidOperationException();