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) {
772
772
}
773
773
774
774
void maybeDeleteRecordedAutoDeleteQueue (String queue ) {
775
- synchronized (this .recordedQueues ) {
776
- synchronized (this .consumers ) {
775
+ synchronized (this .consumers ) {
776
+ synchronized (this .recordedQueues ) {
777
777
if (!hasMoreConsumersOnQueue (this .consumers .values (), queue )) {
778
778
RecordedQueue q = this .recordedQueues .get (queue );
779
779
// last consumer on this connection is gone, remove recorded queue
@@ -787,8 +787,8 @@ void maybeDeleteRecordedAutoDeleteQueue(String queue) {
787
787
}
788
788
789
789
void maybeDeleteRecordedAutoDeleteExchange (String exchange ) {
790
- synchronized (this .recordedExchanges ) {
791
- synchronized (this .consumers ) {
790
+ synchronized (this .consumers ) {
791
+ synchronized (this .recordedExchanges ) {
792
792
if (!hasMoreDestinationsBoundToExchange (Utility .copy (this .recordedBindings ), exchange )) {
793
793
RecordedExchange x = this .recordedExchanges .get (exchange );
794
794
// 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