Skip to content

Commit 480c739

Browse files
Merge pull request #1203 from mot256/6.x
Fix perpetual auto-recovery problem
2 parents e65cb60 + 0477cdc commit 480c739

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
@@ -577,7 +577,7 @@ public void MaybeDeleteRecordedAutoDeleteExchange(string exchange)
577577
// if it is auto-deleted. See bug 26364.
578578
if ((rx != null) && rx.IsAutoDelete)
579579
{
580-
_recordedExchanges.Remove(exchange);
580+
DeleteRecordedExchange(exchange);
581581
}
582582
}
583583
}
@@ -594,7 +594,7 @@ public void MaybeDeleteRecordedAutoDeleteQueue(string queue)
594594
// if it is auto-deleted. See bug 26364.
595595
if ((rq != null) && rq.IsAutoDelete)
596596
{
597-
_recordedQueues.Remove(queue);
597+
DeleteRecordedQueue(queue);
598598
}
599599
}
600600
}
@@ -944,7 +944,7 @@ private void HandleTopologyRecoveryException(TopologyRecoveryException e)
944944

945945
private void PropagateQueueNameChangeToBindings(string oldName, string newName)
946946
{
947-
lock (_recordedBindings)
947+
lock (_recordedEntitiesLock)
948948
{
949949
foreach (RecordedBinding b in _recordedBindings.Keys)
950950
{
@@ -973,7 +973,7 @@ private void PropagateQueueNameChangeToConsumers(string oldName, string newName)
973973
private void RecoverBindings(IModel model)
974974
{
975975
Dictionary<RecordedBinding, byte> recordedBindingsCopy;
976-
lock (_recordedBindings)
976+
lock (_recordedEntitiesLock)
977977
{
978978
recordedBindingsCopy = new Dictionary<RecordedBinding, byte>(_recordedBindings);
979979
}

0 commit comments

Comments
 (0)