Merge pull request #1082 from Pliner/main

michaelklishin · web-flow · commit cdd459c8debe · 2021-10-18T13:06:22.000+03:00
Don't record consumers if topology recovery is off
diff --git 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))

Original file line number	Diff line number	Diff line change
`@@ -176,6 +176,11 @@ internal void DeleteRecordedBinding(in RecordedBinding rb)`
`176`	`176`
`177`	`177`	`internal void RecordConsumer(in RecordedConsumer consumer)`
`178`	`178`	`{`
	`179`	`+ if (!_factory.TopologyRecoveryEnabled)`
	`180`	`+ {`
	`181`	`+ return;`
	`182`	`+ }`
	`183`	`+`
`179`	`184`	`lock (_recordedEntitiesLock)`
`180`	`185`	`{`
`181`	`186`	`_recordedConsumers[consumer.ConsumerTag] = consumer;`
`@@ -184,6 +189,11 @@ internal void RecordConsumer(in RecordedConsumer consumer)`
`184`	`189`
`185`	`190`	`internal void DeleteRecordedConsumer(string consumerTag)`
`186`	`191`	`{`
	`192`	`+ if (!_factory.TopologyRecoveryEnabled)`
	`193`	`+ {`
	`194`	`+ return;`
	`195`	`+ }`
	`196`	`+`
`187`	`197`	`lock (_recordedEntitiesLock)`
`188`	`198`	`{`
`189`	`199`	`if (_recordedConsumers.Remove(consumerTag, out var recordedConsumer))`