Skip to content

Commit f0d8dde

Browse files
authored
Update AutorecoveringConnection.java
1 parent b9fa8f8 commit f0d8dde

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -810,9 +810,9 @@ private void internalRecoverQueue(final String oldName, RecordedQueue q, boolean
810810
if (!oldName.equals(newName)) {
811811
// make sure queues are re-added with
812812
// their new names, if applicable. MK.
813+
propagateQueueNameChangeToBindings(oldName, newName);
814+
propagateQueueNameChangeToConsumers(oldName, newName);
813815
synchronized (this.recordedQueues) {
814-
this.propagateQueueNameChangeToBindings(oldName, newName);
815-
this.propagateQueueNameChangeToConsumers(oldName, newName);
816816
// bug26552:
817817
// remove old name after we've updated the bindings and consumers,
818818
deleteRecordedQueue(oldName);

0 commit comments

Comments
 (0)