Skip to content

Commit 114a9db

Browse files
author
Loïc Hoguin
committed
Revert "Don't kill the gatherer when there's a problem with a queue"
This reverts commit ad20a63.
1 parent 34d0356 commit 114a9db

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)