diff options
| author | Rob Harrop <rob@rabbitmq.com> | 2010-10-08 11:20:49 +0100 |
|---|---|---|
| committer | Rob Harrop <rob@rabbitmq.com> | 2010-10-08 11:20:49 +0100 |
| commit | e203a269a4a8dd5189aba16c88073d6972f48127 (patch) | |
| tree | b463ea6932d07bdce19bc87a36cdc3f78117c5cb | |
| parent | b9a0b9c140fc910891c55c8efd741290dd38371d (diff) | |
| parent | 9c60db6b5eaf9d036d89f70c4a1b9c041e81ab30 (diff) | |
| download | rabbitmq-server-git-e203a269a4a8dd5189aba16c88073d6972f48127.tar.gz | |
merge with default
| -rw-r--r-- | src/rabbit_amqqueue.erl | 27 |
1 files changed, 12 insertions, 15 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 25a061acda..853a409e53 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -449,24 +449,21 @@ flush_all(QPids, ChPid) -> internal_delete1(QueueName) -> ok = mnesia:delete({rabbit_queue, QueueName}), ok = mnesia:delete({rabbit_durable_queue, QueueName}), - %% we want to execute some things, as - %% decided by rabbit_exchange, after the - %% transaction. + %% we want to execute some things, as decided by rabbit_exchange, + %% after the transaction. rabbit_binding:remove_for_queue(QueueName). internal_delete(QueueName) -> - case - rabbit_misc:execute_mnesia_transaction( - fun () -> - case mnesia:wread({rabbit_queue, QueueName}) of - [] -> {error, not_found}; - [_] -> internal_delete1(QueueName) - end - end) of - Err = {error, _} -> Err; - PostHook -> - PostHook(), - ok + case rabbit_misc:execute_mnesia_transaction( + fun () -> + case mnesia:wread({rabbit_queue, QueueName}) of + [] -> {error, not_found}; + [_] -> internal_delete1(QueueName) + end + end) of + {error, _} = Err -> Err; + PostHook -> PostHook(), + ok end. maybe_run_queue_via_backing_queue(QPid, Fun) -> |
