diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-03-28 13:53:58 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-03-28 13:53:58 +0100 |
| commit | 7900e65cf89fc9c28cbef3f1454a1ef61584c94f (patch) | |
| tree | e322c10faf54846aa20de5bff78171888b810375 /src | |
| parent | 947b91d08487476fbf8403f3f09350ef569b117e (diff) | |
| download | rabbitmq-server-git-7900e65cf89fc9c28cbef3f1454a1ef61584c94f.tar.gz | |
cosmetic(ish): shorten arg check fun names and make them more meaningful
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 36 |
1 files changed, 18 insertions, 18 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 1e4e356980..c409fd3e79 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -330,11 +330,11 @@ assert_args_equivalence(#amqqueue{name = QueueName, arguments = Args}, [<<"x-expires">>, <<"x-message-ttl">>, <<"x-ha-policy">>]). check_declare_arguments(QueueName, Args) -> - Checks = [{<<"x-expires">>, fun check_integer_argument/2}, - {<<"x-message-ttl">>, fun check_integer_argument/2}, - {<<"x-ha-policy">>, fun check_ha_policy_argument/2}, - {<<"x-dead-letter-exchange">>, fun check_string_argument/2}, - {<<"x-dead-letter-routing-key">>, fun check_dlxrk_argument/2}], + Checks = [{<<"x-expires">>, fun check_positive_int_arg/2}, + {<<"x-message-ttl">>, fun check_positive_int_arg/2}, + {<<"x-ha-policy">>, fun check_ha_policy_arg/2}, + {<<"x-dead-letter-exchange">>, fun check_string_arg/2}, + {<<"x-dead-letter-routing-key">>, fun check_dlxrk_arg/2}], [case Fun(rabbit_misc:table_lookup(Args, Key), Args) of ok -> ok; {error, Error} -> rabbit_misc:protocol_error( @@ -344,37 +344,37 @@ check_declare_arguments(QueueName, Args) -> end || {Key, Fun} <- Checks], ok. -check_string_argument(undefined, _Args) -> +check_string_arg(undefined, _Args) -> ok; -check_string_argument({longstr, _}, _Args) -> +check_string_arg({longstr, _}, _Args) -> ok; -check_string_argument({Type, _}, _) -> +check_string_arg({Type, _}, _) -> {error, {unacceptable_type, Type}}. -check_integer_argument(undefined, _Args) -> +check_positive_int_arg(undefined, _Args) -> ok; -check_integer_argument({Type, Val}, _Args) -> +check_positive_int_arg({Type, Val}, _Args) -> case lists:member(Type, ?INTEGER_ARG_TYPES) of false -> {error, {unacceptable_type, Type}}; true when Val =< 0 -> {error, {value_zero_or_less, Val}}; true -> ok end. -check_dlxrk_argument(undefined, _Args) -> +check_dlxrk_arg(undefined, _Args) -> ok; -check_dlxrk_argument({longstr, _}, Args) -> +check_dlxrk_arg({longstr, _}, Args) -> case rabbit_misc:table_lookup(Args, <<"x-dead-letter-exchange">>) of undefined -> {error, routing_key_but_no_dlx_defined}; _ -> ok end; -check_dlxrk_argument({Type, _}, _Args) -> +check_dlxrk_arg({Type, _}, _Args) -> {error, {unacceptable_type, Type}}. -check_ha_policy_argument(undefined, _Args) -> +check_ha_policy_arg(undefined, _Args) -> ok; -check_ha_policy_argument({longstr, <<"all">>}, _Args) -> +check_ha_policy_arg({longstr, <<"all">>}, _Args) -> ok; -check_ha_policy_argument({longstr, <<"nodes">>}, Args) -> +check_ha_policy_arg({longstr, <<"nodes">>}, Args) -> case rabbit_misc:table_lookup(Args, <<"x-ha-policy-params">>) of undefined -> {error, {require, 'x-ha-policy-params'}}; @@ -390,9 +390,9 @@ check_ha_policy_argument({longstr, <<"nodes">>}, Args) -> {Type, _} -> {error, {ha_nodes_policy_params_not_array_of_longstr, Type}} end; -check_ha_policy_argument({longstr, Policy}, _Args) -> +check_ha_policy_arg({longstr, Policy}, _Args) -> {error, {invalid_ha_policy, Policy}}; -check_ha_policy_argument({Type, _}, _Args) -> +check_ha_policy_arg({Type, _}, _Args) -> {error, {unacceptable_type, Type}}. list() -> |
