Fix perpetual auto-recovery problem

mot256 · mot256 · commit 359c42bf8aeb · 2022-05-12T17:13:53.000+02:00
diff --git a/projects/RabbitMQ.Client/client/impl/AutorecoveringConnection.Recording.cs b/projects/RabbitMQ.Client/client/impl/AutorecoveringConnection.Recording.cs
@@ -82,7 +82,7 @@ internal void DeleteAutoDeleteExchange(string exchangeName)
                 if (!AnyBindingsOnExchange(exchangeName))
                 {
                     // last binding where this exchange is the source is gone, remove recorded exchange if it is auto-deleted.
-                    _recordedExchanges.Remove(exchangeName);
+                    DeleteRecordedExchange(exchangeName);
                 }
             }
         }
@@ -209,7 +209,7 @@ void DeleteAutoDeleteQueue(string queue)
                 // last consumer on this connection is gone, remove recorded queue if it is auto-deleted.
                 if (!AnyConsumersOnQueue(queue))
                 {
-                    _recordedQueues.Remove(queue);
+                    DeleteRecordedQueue(queue);
                 }
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -82,7 +82,7 @@ internal void DeleteAutoDeleteExchange(string exchangeName)`
`82`	`82`	`if (!AnyBindingsOnExchange(exchangeName))`
`83`	`83`	`{`
`84`	`84`	`// last binding where this exchange is the source is gone, remove recorded exchange if it is auto-deleted.`
`85`		`- _recordedExchanges.Remove(exchangeName);`
	`85`	`+ DeleteRecordedExchange(exchangeName);`
`86`	`86`	`}`
`87`	`87`	`}`
`88`	`88`	`}`
`@@ -209,7 +209,7 @@ void DeleteAutoDeleteQueue(string queue)`
`209`	`209`	`// last consumer on this connection is gone, remove recorded queue if it is auto-deleted.`
`210`	`210`	`if (!AnyConsumersOnQueue(queue))`
`211`	`211`	`{`
`212`		`- _recordedQueues.Remove(queue);`
	`212`	`+ DeleteRecordedQueue(queue);`
`213`	`213`	`}`
`214`	`214`	`}`
`215`	`215`	`}`