Skip to content

Commit 1111ccd

Browse files
Merge branch '4.1.x-stable' into 4.2.x-stable
2 parents 64c8428 + e4fded4 commit 1111ccd

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -783,8 +783,8 @@ RecordedConsumer deleteRecordedConsumer(String consumerTag) {
783783
}
784784

785785
void maybeDeleteRecordedAutoDeleteQueue(String queue) {
786-
synchronized (this.recordedQueues) {
787-
synchronized (this.consumers) {
786+
synchronized (this.consumers) {
787+
synchronized (this.recordedQueues) {
788788
if(!hasMoreConsumersOnQueue(this.consumers.values(), queue)) {
789789
RecordedQueue q = this.recordedQueues.get(queue);
790790
// last consumer on this connection is gone, remove recorded queue
@@ -798,8 +798,8 @@ void maybeDeleteRecordedAutoDeleteQueue(String queue) {
798798
}
799799

800800
void maybeDeleteRecordedAutoDeleteExchange(String exchange) {
801-
synchronized (this.recordedExchanges) {
802-
synchronized (this.consumers) {
801+
synchronized (this.consumers) {
802+
synchronized (this.recordedExchanges) {
803803
if(!hasMoreDestinationsBoundToExchange(Utility.copy(this.recordedBindings), exchange)) {
804804
RecordedExchange x = this.recordedExchanges.get(exchange);
805805
// last binding where this exchange is the source is gone, remove recorded exchange

0 commit comments

Comments
 (0)