File tree 1 file changed +4
-4
lines changed
src/main/java/com/rabbitmq/client/impl/recovery
1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -801,8 +801,8 @@ RecordedConsumer deleteRecordedConsumer(String consumerTag) {
801
801
}
802
802
803
803
void maybeDeleteRecordedAutoDeleteQueue (String queue ) {
804
- synchronized (this .recordedQueues ) {
805
- synchronized (this .consumers ) {
804
+ synchronized (this .consumers ) {
805
+ synchronized (this .recordedQueues ) {
806
806
if (!hasMoreConsumersOnQueue (this .consumers .values (), queue )) {
807
807
RecordedQueue q = this .recordedQueues .get (queue );
808
808
// last consumer on this connection is gone, remove recorded queue
@@ -816,8 +816,8 @@ void maybeDeleteRecordedAutoDeleteQueue(String queue) {
816
816
}
817
817
818
818
void maybeDeleteRecordedAutoDeleteExchange (String exchange ) {
819
- synchronized (this .recordedExchanges ) {
820
- synchronized (this .consumers ) {
819
+ synchronized (this .consumers ) {
820
+ synchronized (this .recordedExchanges ) {
821
821
if (!hasMoreDestinationsBoundToExchange (Utility .copy (this .recordedBindings ), exchange )) {
822
822
RecordedExchange x = this .recordedExchanges .get (exchange );
823
823
// 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