Check DLX permissions on queue declare

1 files changed, 7 insertions, 0 deletions

diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index a8e9432c..3f2f7afa 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -986,6 +986,13 @@ handle_method(#'queue.declare'{queue       = QueueNameBin,
             return_queue_declare_ok(QueueName, NoWait, MessageCount,
                                     ConsumerCount, State);
         {error, not_found} ->
+            case rabbit_misc:r_arg(VHostPath, exchange, Args,
+                                   <<"x-dead-letter-exchange">>) of
+               undefined -> ok;
+               DLX       -> check_read_permitted(QueueName, State),
+                            check_write_permitted(DLX, State),
+                            ok
+            end,
             case rabbit_amqqueue:declare(QueueName, Durable, AutoDelete,
                                          Args, Owner) of
                 {new, #amqqueue{pid = QPid}} ->