summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/rabbit_amqqueue.erl2
-rw-r--r--src/rabbit_mnesia.erl10
2 files changed, 8 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl
index 88ff26cc75..5bd42d9ab2 100644
--- a/src/rabbit_amqqueue.erl
+++ b/src/rabbit_amqqueue.erl
@@ -320,7 +320,7 @@ check_declare_arguments(QueueName, Args) ->
ok -> ok;
{error, Error} -> rabbit_misc:protocol_error(
precondition_failed,
- "invalid arg '~s' for ~s: ~w",
+ "invalid arg '~s' for ~s: ~255p",
[Key, rabbit_misc:rs(QueueName), Error])
end || {Key, Fun} <-
[{<<"x-expires">>, fun check_integer_argument/2},
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl
index c63c67f4ea..1ea909714e 100644
--- a/src/rabbit_mnesia.erl
+++ b/src/rabbit_mnesia.erl
@@ -122,8 +122,10 @@ cluster(ClusterNodes, Force) ->
ensure_mnesia_not_running(),
ensure_mnesia_dir(),
- case not Force andalso is_only_disc_node(node(), false) andalso
- not should_be_disc_node(ClusterNodes) of
+ case not Force andalso is_clustered() andalso
+ is_only_disc_node(node(), false) andalso
+ not should_be_disc_node(ClusterNodes)
+ of
true -> log_both("last running disc node leaving cluster");
_ -> ok
end,
@@ -715,7 +717,9 @@ wait_for_tables(TableNames) ->
reset(Force) ->
ensure_mnesia_not_running(),
- case not Force andalso is_only_disc_node(node(), false) of
+ case not Force andalso is_clustered() andalso
+ is_only_disc_node(node(), false)
+ of
true -> log_both("no other disc nodes running");
false -> ok
end,