File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff 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
You can’t perform that action at this time.
0 commit comments