From dc228a2896d6f29622a6af4418aea34235117be8 Mon Sep 17 00:00:00 2001
From: Yury Pliner <yury.pliner@gmail.com>
Date: Sun, 12 Sep 2021 18:22:30 +0500
Subject: [PATCH] Don't record consumers if topology recovery is off

---
 .../client/impl/AutorecoveringConnection.Recording.cs  | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/projects/RabbitMQ.Client/client/impl/AutorecoveringConnection.Recording.cs b/projects/RabbitMQ.Client/client/impl/AutorecoveringConnection.Recording.cs
index c8ad6f093b..f2db91025f 100644
--- a/projects/RabbitMQ.Client/client/impl/AutorecoveringConnection.Recording.cs
+++ b/projects/RabbitMQ.Client/client/impl/AutorecoveringConnection.Recording.cs
@@ -176,6 +176,11 @@ internal void DeleteRecordedBinding(in RecordedBinding rb)
 
         internal void RecordConsumer(in RecordedConsumer consumer)
         {
+            if (!_factory.TopologyRecoveryEnabled)
+            {
+                return;
+            }
+
             lock (_recordedEntitiesLock)
             {
                 _recordedConsumers[consumer.ConsumerTag] = consumer;
@@ -184,6 +189,11 @@ internal void RecordConsumer(in RecordedConsumer consumer)
 
         internal void DeleteRecordedConsumer(string consumerTag)
         {
+            if (!_factory.TopologyRecoveryEnabled)
+            {
+                return;
+            }
+
             lock (_recordedEntitiesLock)
             {
                 if (_recordedConsumers.Remove(consumerTag, out var recordedConsumer))