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 | 30e146a6d4a9d5028982080cdaaa68ee4b1da020 (patch) | |
tree | b463ea6932d07bdce19bc87a36cdc3f78117c5cb | |
parent | 7abf32f6872b951c2185118262eb5834680812ed (diff) | |
parent | 178c6bc0318d1a471f4a7eb6b29e7e7e63098996 (diff) | |
download | rabbitmq-server-30e146a6d4a9d5028982080cdaaa68ee4b1da020.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 25a061ac..853a409e 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) -> |