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
commit30e146a6d4a9d5028982080cdaaa68ee4b1da020 (patch)
treeb463ea6932d07bdce19bc87a36cdc3f78117c5cb
parent7abf32f6872b951c2185118262eb5834680812ed (diff)
parent178c6bc0318d1a471f4a7eb6b29e7e7e63098996 (diff)
downloadrabbitmq-server-30e146a6d4a9d5028982080cdaaa68ee4b1da020.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 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) ->