summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRob Harrop <rob@rabbitmq.com>2010-10-08 11:20:49 +0100
committerRob Harrop <rob@rabbitmq.com>2010-10-08 11:20:49 +0100
commite203a269a4a8dd5189aba16c88073d6972f48127 (patch)
treeb463ea6932d07bdce19bc87a36cdc3f78117c5cb
parentb9a0b9c140fc910891c55c8efd741290dd38371d (diff)
parent9c60db6b5eaf9d036d89f70c4a1b9c041e81ab30 (diff)
downloadrabbitmq-server-git-e203a269a4a8dd5189aba16c88073d6972f48127.tar.gz
merge with default
-rw-r--r--src/rabbit_amqqueue.erl27
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) ->