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 @@ -1114,8 +1114,8 @@ void maybeDeleteRecordedAutoDeleteQueue(String queue) {
1114
1114
synchronized (this .recordedQueues ) {
1115
1115
if (!hasMoreConsumersOnQueue (this .consumers .values (), queue )) {
1116
1116
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
1119
1119
if (q != null && q .isAutoDelete ()) {
1120
1120
deleteRecordedQueue (queue );
1121
1121
}
@@ -1128,8 +1128,8 @@ void maybeDeleteRecordedAutoDeleteExchange(String exchange) {
1128
1128
synchronized (this .recordedExchanges ) {
1129
1129
if (!hasMoreDestinationsBoundToExchange (Utility .copy (this .recordedBindings ), exchange )) {
1130
1130
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
1133
1133
if (x != null && x .isAutoDelete ()) {
1134
1134
deleteRecordedExchange (exchange );
1135
1135
}
You can’t perform that action at this time.
0 commit comments