diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2012-01-24 19:35:14 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2012-01-24 19:35:14 +0000 |
| commit | f74a2f7fc141c6fbebe10afd86867bb1c4e42d56 (patch) | |
| tree | cd8a6912f93ca44d5b055a78093ad147be8a5139 /src | |
| parent | 2c53e3452477d6063e0424db9cd37371ab9b94c7 (diff) | |
| download | rabbitmq-server-git-f74a2f7fc141c6fbebe10afd86867bb1c4e42d56.tar.gz | |
check dlx routing key arg
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 523a7bba2e..e928008172 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -335,9 +335,19 @@ check_declare_arguments(QueueName = #resource{virtual_host = VHostPath}, [{<<"x-expires">>, fun check_integer_argument/3}, {<<"x-message-ttl">>, fun check_integer_argument/3}, {<<"x-ha-policy">>, fun check_ha_policy_argument/3}, - {<<"x-dead-letter-exchange">>, fun check_exchange_argument/3}]], + {<<"x-dead-letter-exchange">>, + fun check_exchange_argument/3}, + {<<"x-dead-letter-routing-key">>, + fun check_string_argument/3}]], ok. +check_string_argument(undefined, _Args, _VHostPath) -> + ok; +check_string_argument({longstr, _}, _Args, _VHostPath) -> + ok; +check_string_argument({Type, _}, _, _) -> + {error, {unacceptable_type, Type}}. + check_integer_argument(undefined, _Args, _VHostPath) -> ok; check_integer_argument({Type, Val}, _Args, _VHostPath) when Val > 0 -> |