* Connection can be re-created, but publishers/consumers are not re-starting.

Author: lukebakken

RabbitMQ.AMQP.Client/IConnectionSettings.cs

@@ -15,7 +15,7 @@ public interface IConnectionSettings : IEquatable<IConnectionSettings>
     string ContainerId { get; }
     string Path { get; }
     bool UseSsl { get; }
-    uint MaxFrameSize { get; }
+    int MaxFrameSize { get; }
     SaslMechanism SaslMechanism { get; }
     ITlsSettings? TlsSettings { get; }
     IRecoveryConfiguration Recovery { get; }

RabbitMQ.AMQP.Client/Impl/AbstractLifeCycle.cs

@@ -100,10 +100,15 @@ internal async Task ReconnectAsync()
             int randomWait = Random.Shared.Next(300, 900);
             Trace.WriteLine(TraceLevel.Information, $"{ToString()} is reconnecting in {randomWait} ms, " +
                                                     $"attempt: {_backOffDelayPolicy.CurrentAttempt}");
-            await Task.Delay(randomWait).ConfigureAwait(false);
-            await OpenAsync().ConfigureAwait(false);
+            await Task.Delay(randomWait)
+                .ConfigureAwait(false);
+
+            await OpenAsync()
+                .ConfigureAwait(false);
+
             Trace.WriteLine(TraceLevel.Information,
                 $"{ToString()} is reconnected, attempt: {_backOffDelayPolicy.CurrentAttempt}");
+
             _backOffDelayPolicy.Reset();
         }
         catch (Exception e)
@@ -112,11 +117,15 @@ internal async Task ReconnectAsync()
             // that's an edge case, where the link is not ready for some reason
             // the backoff policy will be used to delay the reconnection and give just a few attempts
             Trace.WriteLine(TraceLevel.Error, $"{ToString()} Failed to reconnect, {e.Message}");
+
             int delay = _backOffDelayPolicy.Delay();
-            await Task.Delay(delay).ConfigureAwait(false);
+            await Task.Delay(delay)
+                .ConfigureAwait(false);
+
             if (_backOffDelayPolicy.IsActive())
             {
-                await ReconnectAsync().ConfigureAwait(false);
+                await ReconnectAsync()
+                    .ConfigureAwait(false);
             }
         }
     }