Skip to content

Commit f120d76

Browse files
Merge pull request #8340 from rabbitmq/mergify/bp/v3.12.x/pr-8338
Revert "Don't kill the gatherer when there's a problem with a queue" (backport #8338)
2 parents e6b9afb + 4c7aab8 commit f120d76

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

deps/rabbit/src/rabbit_classic_queue_index_v2.erl

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1114,11 +1114,8 @@ queue_index_walker({start, DurableQueues}) when is_list(DurableQueues) ->
11141114
ok = gatherer:fork(Gatherer),
11151115
ok = worker_pool:submit_async(
11161116
fun () -> link(Gatherer),
1117-
try
1118-
queue_index_walker_reader(QueueName, Gatherer)
1119-
after
1120-
unlink(Gatherer)
1121-
end,
1117+
ok = queue_index_walker_reader(QueueName, Gatherer),
1118+
unlink(Gatherer),
11221119
ok
11231120
end)
11241121
end || QueueName <- DurableQueues],

0 commit comments

Comments
 (0)