diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-06-02 10:44:30 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-06-02 10:44:30 +0100 |
| commit | aacb1cd4fc5daacdea5c69a8dcc3fa14de522956 (patch) | |
| tree | 7aeb7a9c4409fdc53fa023f9a899da73d5ba425b | |
| parent | 5a7e355c3fc2f589c15a72ef8c0f95f0c4a92e08 (diff) | |
| download | rabbitmq-server-aacb1cd4fc5daacdea5c69a8dcc3fa14de522956.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_amqqueue.erl | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index d029ff1d..32798cb2 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -193,12 +193,12 @@ recover_durable_queues(DurableQueues) -> declare(QueueName, Durable, AutoDelete, Args, Owner) -> ok = check_declare_arguments(QueueName, Args), - Q = start_queue_process(#amqqueue{name = QueueName, - durable = Durable, - auto_delete = AutoDelete, - arguments = Args, + Q = start_queue_process(#amqqueue{name = QueueName, + durable = Durable, + auto_delete = AutoDelete, + arguments = Args, exclusive_owner = Owner, - pid = none}), + pid = none}), case gen_server2:call(Q#amqqueue.pid, {init, false}, infinity) of not_found -> rabbit_misc:not_found(QueueName); Q1 -> Q1 @@ -478,11 +478,11 @@ delete_queue(QueueName) -> rabbit_binding:remove_transient_for_destination(QueueName). pseudo_queue(QueueName, Pid) -> - #amqqueue{name = QueueName, - durable = false, + #amqqueue{name = QueueName, + durable = false, auto_delete = false, - arguments = [], - pid = Pid}. + arguments = [], + pid = Pid}. safe_delegate_call_ok(F, Pids) -> case delegate:invoke(Pids, fun (Pid) -> |