From 335f79887e9e59f17abd59c4734899089aaf29f6 Mon Sep 17 00:00:00 2001 From: Alexandru Scvortov Date: Tue, 24 Jan 2012 19:35:14 +0000 Subject: check dlx routing key arg --- src/rabbit_amqqueue.erl | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) (limited to 'src/rabbit_amqqueue.erl') 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 -> -- cgit v1.2.1