From f73aac5ef85badd0de84814c5eb70ec85be261a7 Mon Sep 17 00:00:00 2001 From: alrod Date: Thu, 30 May 2024 14:22:40 -0700 Subject: [PATCH 1/2] [Azure Functions][Queue extesion]Fix queue length --- .../src/Shared/Queues/QueueMetricsProvider.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdk/storage/Microsoft.Azure.WebJobs.Extensions.Storage.Common/src/Shared/Queues/QueueMetricsProvider.cs b/sdk/storage/Microsoft.Azure.WebJobs.Extensions.Storage.Common/src/Shared/Queues/QueueMetricsProvider.cs index 269f2111a0ae..4c6822910820 100644 --- a/sdk/storage/Microsoft.Azure.WebJobs.Extensions.Storage.Common/src/Shared/Queues/QueueMetricsProvider.cs +++ b/sdk/storage/Microsoft.Azure.WebJobs.Extensions.Storage.Common/src/Shared/Queues/QueueMetricsProvider.cs @@ -37,8 +37,8 @@ public async Task GetQueueLengthAsync() { try { - QueueProperties queueProperties = await _queue.GetPropertiesAsync().ConfigureAwait(false); - return queueProperties.ApproximateMessagesCount; + QueueTriggerMetrics queueProperties = await GetMetricsAsync().ConfigureAwait(false); + return queueProperties.QueueLength; } catch (RequestFailedException ex) { From 8ec2053717f8e53050bd445260f4cbe33e076db2 Mon Sep 17 00:00:00 2001 From: alrod Date: Thu, 30 May 2024 14:24:10 -0700 Subject: [PATCH 2/2] queueMetrics --- .../src/Shared/Queues/QueueMetricsProvider.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdk/storage/Microsoft.Azure.WebJobs.Extensions.Storage.Common/src/Shared/Queues/QueueMetricsProvider.cs b/sdk/storage/Microsoft.Azure.WebJobs.Extensions.Storage.Common/src/Shared/Queues/QueueMetricsProvider.cs index 4c6822910820..b10388ef8a93 100644 --- a/sdk/storage/Microsoft.Azure.WebJobs.Extensions.Storage.Common/src/Shared/Queues/QueueMetricsProvider.cs +++ b/sdk/storage/Microsoft.Azure.WebJobs.Extensions.Storage.Common/src/Shared/Queues/QueueMetricsProvider.cs @@ -37,8 +37,8 @@ public async Task GetQueueLengthAsync() { try { - QueueTriggerMetrics queueProperties = await GetMetricsAsync().ConfigureAwait(false); - return queueProperties.QueueLength; + QueueTriggerMetrics queueMetrics = await GetMetricsAsync().ConfigureAwait(false); + return queueMetrics.QueueLength; } catch (RequestFailedException ex) {