summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <michael@clojurewerkz.org>2020-03-12 19:29:26 +0300
committerMichael Klishin <michael@clojurewerkz.org>2020-03-12 19:29:26 +0300
commit4e970134a55f5ccb2ab4726f62524f3313a3f190 (patch)
treea35e62319e323ca1f3b1ff9c6b66143d26d51147
parent21a63b205196b5ba9ab874d9488e6414f9ff6342 (diff)
downloadrabbitmq-server-git-4e970134a55f5ccb2ab4726f62524f3313a3f190.tar.gz
Revert "Use default work pool for definition import"
This reverts commit 1a60b43aa99bb8d97fe29a3c5266ede7678fe26e.
-rw-r--r--src/rabbit_definitions.erl1
1 files changed, 1 insertions, 0 deletions
diff --git a/src/rabbit_definitions.erl b/src/rabbit_definitions.erl
index 30f846a657..fd4ae08ccf 100644
--- a/src/rabbit_definitions.erl
+++ b/src/rabbit_definitions.erl
@@ -350,6 +350,7 @@ do_concurrent_for_all(List, WorkPoolFun) ->
%% keys are expected to be atoms
ok = gatherer:fork(Gatherer),
worker_pool:submit_async(
+ ?IMPORT_WORK_POOL,
fun() ->
try
WorkPoolFun(M)