Skip to content

Commit be0a7e9

Browse files
Merge pull request #1203 from mot256/6.x
Fix perpetual auto-recovery problem (cherry picked from commit 480c739)
1 parent 7483767 commit be0a7e9

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

projects/RabbitMQ.Client/client/impl/AutorecoveringConnection.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -545,7 +545,7 @@ public void MaybeDeleteRecordedAutoDeleteExchange(string exchange)
545545
// if it is auto-deleted. See bug 26364.
546546
if ((rx != null) && rx.IsAutoDelete)
547547
{
548-
_recordedExchanges.Remove(exchange);
548+
DeleteRecordedExchange(exchange);
549549
}
550550
}
551551
}
@@ -562,7 +562,7 @@ public void MaybeDeleteRecordedAutoDeleteQueue(string queue)
562562
// if it is auto-deleted. See bug 26364.
563563
if ((rq != null) && rq.IsAutoDelete)
564564
{
565-
_recordedQueues.Remove(queue);
565+
DeleteRecordedQueue(queue);
566566
}
567567
}
568568
}
@@ -900,7 +900,7 @@ private void HandleTopologyRecoveryException(TopologyRecoveryException e)
900900

901901
private void PropagateQueueNameChangeToBindings(string oldName, string newName)
902902
{
903-
lock (_recordedBindings)
903+
lock (_recordedEntitiesLock)
904904
{
905905
foreach (RecordedBinding b in _recordedBindings.Keys)
906906
{
@@ -929,7 +929,7 @@ private void PropagateQueueNameChangeToConsumers(string oldName, string newName)
929929
private void RecoverBindings()
930930
{
931931
Dictionary<RecordedBinding, byte> recordedBindingsCopy;
932-
lock (_recordedBindings)
932+
lock (_recordedEntitiesLock)
933933
{
934934
recordedBindingsCopy = new Dictionary<RecordedBinding, byte>(_recordedBindings);
935935
}

0 commit comments

Comments
 (0)