diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_msg_store.erl | 6 | ||||
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
2 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 6e404ea7ca..d5c0031944 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -722,7 +722,7 @@ init([Type, BaseDir, ClientRefs, StartupFunState]) -> Name = filename:join(filename:basename(BaseDir), atom_to_list(Type)), {ok, IndexModule} = application:get_env(rabbit, msg_store_index_module), - rabbit_log:info("~tp: using ~p to provide index~n", [Name, IndexModule]), + rabbit_log:info("Message store ~tp: using ~p to provide index~n", [Name, IndexModule]), AttemptFileSummaryRecovery = case ClientRefs of @@ -1548,11 +1548,11 @@ index_delete_by_file(File, #msstate { index_module = Index, recover_index_and_client_refs(IndexModule, _Recover, undefined, Dir, _Name) -> {false, IndexModule:new(Dir), []}; recover_index_and_client_refs(IndexModule, false, _ClientRefs, Dir, Name) -> - rabbit_log:warning("~tp : rebuilding indices from scratch~n", [Name]), + rabbit_log:warning("Message store ~tp: rebuilding indices from scratch~n", [Name]), {false, IndexModule:new(Dir), []}; recover_index_and_client_refs(IndexModule, true, ClientRefs, Dir, Name) -> Fresh = fun (ErrorMsg, ErrorArgs) -> - rabbit_log:warning("~tp : " ++ ErrorMsg ++ "~n" + rabbit_log:warning("Message store ~tp : " ++ ErrorMsg ++ "~n" "rebuilding indices from scratch~n", [Name | ErrorArgs]), {false, IndexModule:new(Dir), []} diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index f40e46c80d..c0495bbb4b 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -525,10 +525,10 @@ start_msg_store(Refs, StartFunState) when is_map(Refs); Refs == undefined -> ok. add_vhost_msg_store(VHost) -> - rabbit_log:info("Starting message store vor vhost ~p~n", [VHost]), + rabbit_log:info("Starting message stores for vhost '~s'~n", [VHost]), rabbit_msg_store_vhost_sup:add_vhost(?TRANSIENT_MSG_STORE_SUP, VHost), rabbit_msg_store_vhost_sup:add_vhost(?PERSISTENT_MSG_STORE_SUP, VHost), - rabbit_log:info("Message store is started vor vhost ~p~n", [VHost]). + rabbit_log:info("Message stores for vhost '~s' are started~n", [VHost]). stop_msg_store() -> ok = rabbit_sup:stop_child(?PERSISTENT_MSG_STORE_SUP), |