add support for configuring MessageVisibilityTimeout

dotnet · Oct 7, 2024 · 95caf09 · 95caf09
1 parent bb10791
commit 95caf09
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/Azure/Orleans.Streaming.AzureStorage/Hosting/AzureQueueStreamProviderBuilder.cs b/src/Azure/Orleans.Streaming.AzureStorage/Hosting/AzureQueueStreamProviderBuilder.cs
@@ -38,6 +38,12 @@ private static Action<OptionsBuilder<AzureQueueOptions>> GetQueueOptionBuilder(I
                     options.QueueNames = queueNames;
                 }
 
+                var visibilityTimeout = configurationSection["MessageVisibilityTimeout"];
+                if (TimeSpan.TryParse(visibilityTimeout, out var visibilityTimeoutTimeSpan))
+                {
+                    options.MessageVisibilityTimeout = visibilityTimeoutTimeSpan;
+                }
+
                 var serviceKey = configurationSection["ServiceKey"];
                 if (!string.IsNullOrEmpty(serviceKey))
                 {