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 | 335f79887e9e59f17abd59c4734899089aaf29f6 (patch) | |
| tree | cd8a6912f93ca44d5b055a78093ad147be8a5139 /src/rabbit_amqqueue.erl | |
| parent | 1bdfd315b5d1c449bf2a53deee9021b160719310 (diff) | |
| download | rabbitmq-server-335f79887e9e59f17abd59c4734899089aaf29f6.tar.gz | |
check dlx routing key arg
Diffstat (limited to 'src/rabbit_amqqueue.erl')
| -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 523a7bba..e9280081 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 -> |