summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMichael Klishin <mklishin@pivotal.io>2017-02-20 19:23:19 +0300
committerMichael Klishin <mklishin@pivotal.io>2017-02-20 19:23:19 +0300
commit23f80ac04884ea08d2f8c1b567abd5689c8553e5 (patch)
treebc26425044208a794479c9dd0a31f891855876ab /src
parent0b777c76bcf65c73328caa0726eafd98e6824c8e (diff)
downloadrabbitmq-server-git-23f80ac04884ea08d2f8c1b567abd5689c8553e5.tar.gz
Improve logging a bit
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_msg_store.erl6
-rw-r--r--src/rabbit_variable_queue.erl4
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),