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 @@ -1114,8 +1114,8 @@ void maybeDeleteRecordedAutoDeleteQueue(String queue) {
11141114 synchronized (this .recordedQueues ) {
11151115 if (!hasMoreConsumersOnQueue (this .consumers .values (), queue )) {
11161116 RecordedQueue q = this .recordedQueues .get (queue );
1117- // last consumer on this connection is gone, remove recorded queue
1118- // if it is auto-deleted. See bug 26364.
1117+ // the last consumer on this connection is gone, remove the recorded queue
1118+ // if it is auto-deleted
11191119 if (q != null && q .isAutoDelete ()) {
11201120 deleteRecordedQueue (queue );
11211121 }
@@ -1128,8 +1128,8 @@ void maybeDeleteRecordedAutoDeleteExchange(String exchange) {
11281128 synchronized (this .recordedExchanges ) {
11291129 if (!hasMoreDestinationsBoundToExchange (Utility .copy (this .recordedBindings ), exchange )) {
11301130 RecordedExchange x = this .recordedExchanges .get (exchange );
1131- // last binding where this exchange is the source is gone, remove recorded exchange
1132- // if it is auto-deleted. See bug 26364.
1131+ // the last binding where this exchange is the source is gone, remove the recorded exchange
1132+ // if it is auto-deleted
11331133 if (x != null && x .isAutoDelete ()) {
11341134 deleteRecordedExchange (exchange );
11351135 }
You can’t perform that action at this time.
0 commit comments