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);