diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2021-11-05 15:27:48 +0000 |
|---|---|---|
| committer | Karl Nilsson <kjnilsson@gmail.com> | 2021-11-05 15:27:48 +0000 |
| commit | 309e0feb9b32878ebca88d2390dc934a1970ee67 (patch) | |
| tree | d7a4382f6d3eee6d1f2e95e3f2584392bd72e49c | |
| parent | f2f99c9088a8262239a3d671fb15287108746953 (diff) | |
| download | rabbitmq-server-git-qq-messages-pending-fixes.tar.gz | |
Log recovery time by queue typeqq-messages-pending-fixes
| -rw-r--r-- | deps/rabbit/src/rabbit_queue_type.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/deps/rabbit/src/rabbit_queue_type.erl b/deps/rabbit/src/rabbit_queue_type.erl index 886e0ba7e8..128d0a2bd0 100644 --- a/deps/rabbit/src/rabbit_queue_type.erl +++ b/deps/rabbit/src/rabbit_queue_type.erl @@ -384,7 +384,9 @@ recover(VHost, Qs) -> rabbit_quorum_queue => [], rabbit_stream_queue => []}, Qs), maps:fold(fun (Mod, Queues, {R0, F0}) -> - {R, F} = Mod:recover(VHost, Queues), + {Taken, {R, F}} = timer:tc(Mod, recover, [VHost, Queues]), + rabbit_log:info("Recovering ~b queues of type ~s took ~bms", + [length(Queues), Mod, Taken div 1000]), {R0 ++ R, F0 ++ F} end, {[], []}, ByType). |