File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
src/main/java/com/rabbitmq/client/impl/recovery Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff 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
You can’t perform that action at this time.
0 commit comments