diff options
| author | Simon MacMullen <simon@lshift.net> | 2010-05-26 12:23:31 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@lshift.net> | 2010-05-26 12:23:31 +0100 |
| commit | 9ecd9112a63ee568840bfc56da92d997434e586d (patch) | |
| tree | af0c1e2c5d988b90881b21281176c8bcf6c9bd72 | |
| parent | c5014e928a2d63268c15060fbdbc7beeb7a80802 (diff) | |
| download | rabbitmq-server-9ecd9112a63ee568840bfc56da92d997434e586d.tar.gz | |
Reinstate check_configure_permitted in queue.declare passive when queue already exists.
| -rw-r--r-- | src/rabbit_channel.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 2a3237b9..2d7bfd4e 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -737,8 +737,9 @@ handle_method(#'queue.declare'{queue = QueueNameBin, check_configure_permitted(QueueName, State), Finish(rabbit_amqqueue:declare(QueueName, Durable, AutoDelete, Args, Owner)); - Found -> - Found + Other = #amqqueue{name = QueueName} -> + check_configure_permitted(QueueName, State), + Other end, return_queue_declare_ok(State, NoWait, Q); |