From d9fc3497e7ab9aaf673152d78429ef03f5b77e69 Mon Sep 17 00:00:00 2001 From: claimundefine Date: Tue, 18 Nov 2025 05:27:15 -0500 Subject: [PATCH] Ensure single use of HttpRequestMessage for token fetch --- .../BearerAuthenticationHeaderValueProvider.cs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/Confluent.SchemaRegistry/Rest/Authentication/BearerAuthenticationHeaderValueProvider.cs b/src/Confluent.SchemaRegistry/Rest/Authentication/BearerAuthenticationHeaderValueProvider.cs index 576411d92..3efd4bc12 100644 --- a/src/Confluent.SchemaRegistry/Rest/Authentication/BearerAuthenticationHeaderValueProvider.cs +++ b/src/Confluent.SchemaRegistry/Rest/Authentication/BearerAuthenticationHeaderValueProvider.cs @@ -87,12 +87,11 @@ private HttpRequestMessage CreateTokenRequest() } private async Task GenerateToken() - { - var request = CreateTokenRequest(); - + { for (int i = 0; i < maxRetries + 1; i++){ try { + var request = CreateTokenRequest(); var response = await httpClient.SendAsync(request).ConfigureAwait(continueOnCapturedContext: false); response.EnsureSuccessStatusCode(); var tokenResponse = await response.Content.ReadAsStringAsync().ConfigureAwait(false); @@ -104,7 +103,8 @@ private async Task GenerateToken() { if (i == maxRetries) { - throw new Exception("Failed to fetch token from server: " + e.Message); + throw new Exception( + $"Failed to fetch token from server: {e.GetType().FullName} - {e.Message}"); } await Task.Delay(RetryUtility.CalculateRetryDelay(retriesWaitMs, retriesMaxWaitMs, i)) .ConfigureAwait(false);