abort autorecovery if topology cant be recovered because of connection problem

Pierre Setteskog · Pierre Setteskog · commit 5a873e43df79 · 2021-05-31T16:35:14.000+02:00
diff --git a/projects/RabbitMQ.Client/client/impl/AutorecoveringConnection.cs b/projects/RabbitMQ.Client/client/impl/AutorecoveringConnection.cs
@@ -896,7 +896,12 @@ private void EnsureIsOpen()
         private void HandleTopologyRecoveryException(TopologyRecoveryException e)
         {
             ESLog.Error("Topology recovery exception", e);
-            throw e;
+            if (e.InnerException is AlreadyClosedException || e.InnerException is OperationInterruptedException || e.InnerException is TimeoutException)
+            {
+                throw e;
+            }
+            ESLog.Error($"Will not throw Topology Exception {e.InnerException?.GetType().FullName}.", e);
+
         }
 
         private void PropagateQueueNameChangeToBindings(string oldName, string newName)

Original file line number	Diff line number	Diff line change
`@@ -896,7 +896,12 @@ private void EnsureIsOpen()`
`896`	`896`	`private void HandleTopologyRecoveryException(TopologyRecoveryException e)`
`897`	`897`	`{`
`898`	`898`	`ESLog.Error("Topology recovery exception", e);`
`899`		`- throw e;`
	`899`	`+ if (e.InnerException is AlreadyClosedException \|\| e.InnerException is OperationInterruptedException \|\| e.InnerException is TimeoutException)`
	`900`	`+ {`
	`901`	`+ throw e;`
	`902`	`+ }`
	`903`	`+ ESLog.Error($"Will not throw Topology Exception {e.InnerException?.GetType().FullName}.", e);`
	`904`	`+`
`900`	`905`	`}`
`901`	`906`
`902`	`907`	`private void PropagateQueueNameChangeToBindings(string oldName, string newName)`