summaryrefslogtreecommitdiff
path: root/src/rabbit.erl
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2011-10-03 14:08:04 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2011-10-03 14:08:04 +0100
commit587e3cf8aa4c4308662b957b1a374a468402f70c (patch)
treee7f97f77dfe68fda3985dc53e6498029bc085b0e /src/rabbit.erl
parent8d4b3262130d7ebe02aed4428dbcc75bb86d00f6 (diff)
parent88a9a3402a628c7e8061105746b1a380503095d8 (diff)
downloadrabbitmq-server-git-587e3cf8aa4c4308662b957b1a374a468402f70c.tar.gz
merge bug24323 into default
Diffstat (limited to 'src/rabbit.erl')
-rw-r--r--src/rabbit.erl29
1 files changed, 20 insertions, 9 deletions
diff --git a/src/rabbit.erl b/src/rabbit.erl
index 8feeb3649d..e98ca9be33 100644
--- a/src/rabbit.erl
+++ b/src/rabbit.erl
@@ -206,6 +206,14 @@
-spec(boot_delegate/0 :: () -> 'ok').
-spec(recover/0 :: () -> 'ok').
+-spec(start/2 :: ('normal',[]) ->
+ {'error',
+ {'erlang_version_too_old',
+ {'found',[any()]},
+ {'required',[any(),...]}}} |
+ {'ok',pid()}).
+-spec(stop/1 :: (_) -> 'ok').
+
-endif.
%%----------------------------------------------------------------------------
@@ -224,12 +232,14 @@ start() ->
end.
stop() ->
+ rabbit_log:info("Stopping Rabbit~n"),
ok = rabbit_misc:stop_applications(application_load_order()).
stop_and_halt() ->
try
stop()
after
+ rabbit_misc:local_info_msg("Halting Erlang VM~n", []),
init:stop()
end,
ok.
@@ -262,6 +272,7 @@ environment() ->
rotate_logs(BinarySuffix) ->
Suffix = binary_to_list(BinarySuffix),
+ rabbit_misc:local_info_msg("Rotating logs with suffix '~s'~n", [Suffix]),
log_rotation_result(rotate_logs(log_location(kernel),
Suffix,
rabbit_error_logger_file_h),
@@ -459,20 +470,20 @@ insert_default_data() ->
ensure_working_log_handlers() ->
Handlers = gen_event:which_handlers(error_logger),
- ok = ensure_working_log_handler(error_logger_file_h,
+ ok = ensure_working_log_handler(error_logger_tty_h,
rabbit_error_logger_file_h,
error_logger_tty_h,
log_location(kernel),
Handlers),
- ok = ensure_working_log_handler(sasl_report_file_h,
+ ok = ensure_working_log_handler(sasl_report_tty_h,
rabbit_sasl_report_file_h,
sasl_report_tty_h,
log_location(sasl),
Handlers),
ok.
-ensure_working_log_handler(OldFHandler, NewFHandler, TTYHandler,
+ensure_working_log_handler(OldHandler, NewHandler, TTYHandler,
LogLocation, Handlers) ->
case LogLocation of
undefined -> ok;
@@ -482,10 +493,10 @@ ensure_working_log_handler(OldFHandler, NewFHandler, TTYHandler,
throw({error, {cannot_log_to_tty,
TTYHandler, not_installed}})
end;
- _ -> case lists:member(NewFHandler, Handlers) of
+ _ -> case lists:member(NewHandler, Handlers) of
true -> ok;
false -> case rotate_logs(LogLocation, "",
- OldFHandler, NewFHandler) of
+ OldHandler, NewHandler) of
ok -> ok;
{error, Reason} ->
throw({error, {cannot_log_to_file,
@@ -495,10 +506,10 @@ ensure_working_log_handler(OldFHandler, NewFHandler, TTYHandler,
end.
log_location(Type) ->
- case application:get_env(Type, case Type of
- kernel -> error_logger;
- sasl -> sasl_error_logger
- end) of
+ case application:get_env(rabbit, case Type of
+ kernel -> error_logger;
+ sasl -> sasl_error_logger
+ end) of
{ok, {file, File}} -> File;
{ok, false} -> undefined;
{ok, tty} -> tty;