* Debugging

Author: lukebakken

projects/RabbitMQ.Client.OAuth2/CredentialsRefresher.cs

@@ -93,6 +93,8 @@ private async Task RefreshLoopAsync()
                     }
 
                     CredentialsRefresherEventSource.Log.RefreshedCredentials(_credentialsProvider.Name);
+
+                    Console.WriteLine("{0} [DEBUG] calling _onRefreshed, ValidUntil: {1}", DateTime.Now, _credentials.ValidUntil);
                     await _onRefreshed(_credentials, null, _linkedCts.Token)
                         .ConfigureAwait(false);
                 }
@@ -112,6 +114,8 @@ await _onRefreshed(null, ex, _linkedCts.Token)
                     delaySpan = TimeSpan.FromMilliseconds(_credentials.ValidUntil.Value.TotalMilliseconds * (1.0 - (1 / 3.0)));
                 }
 
+                Console.WriteLine("{0} [DEBUG] RefreshLoopAsync delaySpan : {1}",
+                    DateTime.Now, delaySpan);
                 await Task.Delay(delaySpan, _linkedCts.Token)
                     .ConfigureAwait(false);
             }

projects/Test/Common/Util.cs

@@ -26,7 +26,7 @@ public Util(string managementUsername, string managementPassword)
         {
             if (string.IsNullOrEmpty(managementUsername))
             {
-                throw new ArgumentNullException(nameof(managementUsername));
+                managementUsername = "guest";
             }
 
             if (string.IsNullOrEmpty(managementPassword))

projects/Test/OAuth2/TestOAuth2.cs

@@ -208,13 +208,17 @@ public async Task DisposeAsync()
         private Task OnCredentialsRefreshedAsync(Credentials? credentials, Exception? exception,
             CancellationToken cancellationToken = default)
         {
+            Console.WriteLine("{0} [INFO] OnCredentialsRefreshedAsync start", DateTime.Now);
+
             if (_connection is null)
             {
                 Assert.Fail("_connection is unexpectedly null!");
             }
 
             if (exception != null)
             {
+                Console.WriteLine("{0} [ERROR] OnCredentialsRefreshedAsync exception: {1}",
+                    DateTime.Now, exception);
                 Assert.Fail($"exception is unexpectedly not-null: {exception}");
             }
 
@@ -227,9 +231,10 @@ private Task OnCredentialsRefreshedAsync(Credentials? credentials, Exception? ex
             {
                 _util.Dispose();
             }
-            _util = new Util(credentials.UserName, credentials.Password);
+            _util = new Util("mgt_api_client", credentials.Password);
 
             _testOutputHelper.WriteLine("{0} [INFO] calling UpdateSecretAsync", DateTime.Now);
+            Console.WriteLine("{0} [INFO] calling UpdateSecretAsync", DateTime.Now);
             return _connection.UpdateSecretAsync(credentials.Password, "Token refresh", cancellationToken);
         }
 
@@ -253,7 +258,7 @@ public async void IntegrationTest()
                             _testOutputHelper.WriteLine("{0} [INFO] wait '{1}' until Token expires. Attempt #{1}",
                                 DateTime.Now, delaySpan, (i + 1));
 
-                            if (i == 2)
+                            if (i == 1)
                             {
                                 Assert.NotNull(_util);
                                 closeConnectionTask = _util.CloseConnectionAsync(_connection);