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) {
1118
1118
synchronized (this .recordedQueues ) {
1119
1119
if (!hasMoreConsumersOnQueue (this .consumers .values (), queue )) {
1120
1120
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
1123
1123
if (q != null && q .isAutoDelete ()) {
1124
1124
deleteRecordedQueue (queue );
1125
1125
}
@@ -1132,8 +1132,8 @@ void maybeDeleteRecordedAutoDeleteExchange(String exchange) {
1132
1132
synchronized (this .recordedExchanges ) {
1133
1133
if (!hasMoreDestinationsBoundToExchange (Utility .copy (this .recordedBindings ), exchange )) {
1134
1134
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
1137
1137
if (x != null && x .isAutoDelete ()) {
1138
1138
deleteRecordedExchange (exchange );
1139
1139
}
You can’t perform that action at this time.
0 commit comments