Skip to content

Commit cef66a3

Browse files
Improve queue index migration
A failure to locate source directory should be logged as an error into both upgrade and regular log for extra visibility. See https://groups.google.com/forum/#!topic/rabbitmq-users/toq2dpocm0k for background. (cherry picked from commit 8f7b78c)
1 parent 88f6a89 commit cef66a3

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

src/rabbit_queue_index.erl

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1456,14 +1456,18 @@ move_to_per_vhost_stores(#resource{} = QueueName) ->
14561456
OldQueueDir = filename:join([queues_base_dir(), "queues",
14571457
queue_name_to_dir_name_legacy(QueueName)]),
14581458
NewQueueDir = queue_dir(QueueName),
1459+
rabbit_log_upgrade:info("About to migrate queue directory '~s' to '~s'",
1460+
[OldQueueDir, NewQueueDir]),
14591461
case rabbit_file:is_dir(OldQueueDir) of
14601462
true ->
14611463
ok = rabbit_file:ensure_dir(NewQueueDir),
14621464
ok = rabbit_file:rename(OldQueueDir, NewQueueDir),
14631465
ok = ensure_queue_name_stub_file(NewQueueDir, QueueName);
14641466
false ->
1465-
rabbit_log:info("Queue index directory not found for queue ~p~n",
1466-
[QueueName])
1467+
Msg = "Queue index directory '~s' not found for ~s~n",
1468+
Args = [OldQueueDir, rabbit_misc:rs(QueueName)],
1469+
rabbit_log_upgrade:error(Msg, Args),
1470+
rabbit_log:error(Msg, Args)
14671471
end,
14681472
ok.
14691473

0 commit comments

Comments
 (0)