summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2011-06-22 12:28:01 +0100
committerMatthew Sackman <matthew@rabbitmq.com>2011-06-22 12:28:01 +0100
commitf32d634776ae501415860c1e6452a0c558d8c775 (patch)
tree41f6c2d5097c934fcccd5139d51a872593cc39f3
parent079ccc099706ea5d733548df1dfe279ee43a3802 (diff)
downloadrabbitmq-server-f32d634776ae501415860c1e6452a0c558d8c775.tar.gz
Be more helpful...and make it compile
-rw-r--r--src/rabbit_amqqueue.erl4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl
index f2a00ebd..36701631 100644
--- a/src/rabbit_amqqueue.erl
+++ b/src/rabbit_amqqueue.erl
@@ -353,13 +353,13 @@ check_ha_policy_argument(undefined, _Args) ->
ok;
check_ha_policy_argument({longstr, <<"all">>}, _Args) ->
ok;
-check_ha_policy_argument({longstr, <<"nodes">>}, _Args) ->
+check_ha_policy_argument({longstr, <<"nodes">>}, Args) ->
case rabbit_misc:table_lookup(Args, <<"x-ha-policy-params">>) of
undefined ->
{error, {require, <<"x-ha-policy-params">>}};
{array, Ary} ->
case lists:all(fun ({longstr, _Node}) -> true;
- _ -> false
+ (_ ) -> false
end, Ary) of
true -> ok;
false -> {error, {require_list_of_nodes_as_longstrs, Ary}}