From 95caf0976c6dfb06b114ee942d5a414a0bc68e57 Mon Sep 17 00:00:00 2001 From: Taylor Kimmett Date: Wed, 25 Sep 2024 20:45:39 -0400 Subject: [PATCH] add support for configuring MessageVisibilityTimeout --- .../Hosting/AzureQueueStreamProviderBuilder.cs | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/Azure/Orleans.Streaming.AzureStorage/Hosting/AzureQueueStreamProviderBuilder.cs b/src/Azure/Orleans.Streaming.AzureStorage/Hosting/AzureQueueStreamProviderBuilder.cs index 3968355d8c..c3b9b4c921 100644 --- 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> 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)) {