Skip to content

Commit 023eec0

Browse files
Merge pull request #8338 from rabbitmq/lh-revert-ad20a63
Revert "Don't kill the gatherer when there's a problem with a queue"
2 parents 75d7609 + 114a9db commit 023eec0

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)