Skip to content

Commit e843364

Browse files
committed
Fix permanent auto-recovery failure
1 parent 369a6f7 commit e843364

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
}
@@ -937,7 +937,7 @@ private void HandleTopologyRecoveryException(TopologyRecoveryException e)
937937

938938
private void PropagateQueueNameChangeToBindings(string oldName, string newName)
939939
{
940-
lock (_recordedBindings)
940+
lock (_recordedEntitiesLock)
941941
{
942942
foreach (RecordedBinding b in _recordedBindings.Keys)
943943
{
@@ -966,7 +966,7 @@ private void PropagateQueueNameChangeToConsumers(string oldName, string newName)
966966
private void RecoverBindings(IModel model)
967967
{
968968
Dictionary<RecordedBinding, byte> recordedBindingsCopy;
969-
lock (_recordedBindings)
969+
lock (_recordedEntitiesLock)
970970
{
971971
recordedBindingsCopy = new Dictionary<RecordedBinding, byte>(_recordedBindings);
972972
}

0 commit comments

Comments
 (0)