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 @@ -772,8 +772,8 @@ RecordedConsumer deleteRecordedConsumer(String consumerTag) {
772772 }
773773
774774 void maybeDeleteRecordedAutoDeleteQueue (String queue ) {
775- synchronized (this .recordedQueues ) {
776- synchronized (this .consumers ) {
775+ synchronized (this .consumers ) {
776+ synchronized (this .recordedQueues ) {
777777 if (!hasMoreConsumersOnQueue (this .consumers .values (), queue )) {
778778 RecordedQueue q = this .recordedQueues .get (queue );
779779 // last consumer on this connection is gone, remove recorded queue
@@ -787,8 +787,8 @@ void maybeDeleteRecordedAutoDeleteQueue(String queue) {
787787 }
788788
789789 void maybeDeleteRecordedAutoDeleteExchange (String exchange ) {
790- synchronized (this .recordedExchanges ) {
791- synchronized (this .consumers ) {
790+ synchronized (this .consumers ) {
791+ synchronized (this .recordedExchanges ) {
792792 if (!hasMoreDestinationsBoundToExchange (Utility .copy (this .recordedBindings ), exchange )) {
793793 RecordedExchange x = this .recordedExchanges .get (exchange );
794794 // 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