diff options
| -rw-r--r-- | src/rabbit_definitions.erl | 1 |
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) |