From f0d8dde48b928e599fdb98403cbf7d157d5d2f19 Mon Sep 17 00:00:00 2001
From: Michael Dent <vikinghawk@users.noreply.github.com>
Date: Wed, 25 May 2022 15:28:45 -0500
Subject: [PATCH] Update AutorecoveringConnection.java

---
 .../client/impl/recovery/AutorecoveringConnection.java        | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java b/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java
index 9cb0dbff59..743fdd8958 100644
--- a/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java
+++ b/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java
@@ -810,9 +810,9 @@ private void internalRecoverQueue(final String oldName, RecordedQueue q, boolean
             if (!oldName.equals(newName)) {
                 // make sure queues are re-added with
                 // their new names, if applicable. MK.
+                propagateQueueNameChangeToBindings(oldName, newName);
+                propagateQueueNameChangeToConsumers(oldName, newName);
                 synchronized (this.recordedQueues) {
-                    this.propagateQueueNameChangeToBindings(oldName, newName);
-                    this.propagateQueueNameChangeToConsumers(oldName, newName);
                     // bug26552:
                     // remove old name after we've updated the bindings and consumers,
                     deleteRecordedQueue(oldName);