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 @@ -1118,8 +1118,8 @@ void maybeDeleteRecordedAutoDeleteQueue(String queue) {
11181118 synchronized (this .recordedQueues ) {
11191119 if (!hasMoreConsumersOnQueue (this .consumers .values (), queue )) {
11201120 RecordedQueue q = this .recordedQueues .get (queue );
1121- // last consumer on this connection is gone, remove recorded queue
1122- // if it is auto-deleted. See bug 26364.
1121+ // the last consumer on this connection is gone, remove the recorded queue
1122+ // if it is auto-deleted
11231123 if (q != null && q .isAutoDelete ()) {
11241124 deleteRecordedQueue (queue );
11251125 }
@@ -1132,8 +1132,8 @@ void maybeDeleteRecordedAutoDeleteExchange(String exchange) {
11321132 synchronized (this .recordedExchanges ) {
11331133 if (!hasMoreDestinationsBoundToExchange (Utility .copy (this .recordedBindings ), exchange )) {
11341134 RecordedExchange x = this .recordedExchanges .get (exchange );
1135- // last binding where this exchange is the source is gone, remove recorded exchange
1136- // if it is auto-deleted. See bug 26364.
1135+ // the last binding where this exchange is the source is gone, remove the recorded exchange
1136+ // if it is auto-deleted
11371137 if (x != null && x .isAutoDelete ()) {
11381138 deleteRecordedExchange (exchange );
11391139 }
You can’t perform that action at this time.
0 commit comments