diff options
| author | Tim Watson <tim@rabbitmq.com> | 2014-02-05 16:57:55 +0000 |
|---|---|---|
| committer | Tim Watson <tim@rabbitmq.com> | 2014-02-05 16:57:55 +0000 |
| commit | 4cfff0dccbfb5286a1704004beeb4ca1c1f9cb38 (patch) | |
| tree | 698d190768f145d27856629ffc1773e676704444 | |
| parent | df11b4e85f31a8a39097e40f5c0f6046f0394d06 (diff) | |
| download | rabbitmq-server-git-4cfff0dccbfb5286a1704004beeb4ca1c1f9cb38.tar.gz | |
Use dirty opts to find durable queues during startup (and optimise)
| -rw-r--r-- | src/rabbit_amqqueue.erl | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 411ae502db..a6793f9476 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -221,14 +221,13 @@ start(Qs) -> find_durable_queues() -> Node = node(), - %% TODO: use dirty ops instead - rabbit_misc:execute_mnesia_transaction( + mnesia:async_dirty( fun () -> qlc:e(qlc:q([Q || Q = #amqqueue{name = Name, pid = Pid} <- mnesia:table(rabbit_durable_queue), - mnesia:read(rabbit_queue, Name, read) =:= [], - node(Pid) == Node])) + node(Pid) == Node, + mnesia:read(rabbit_queue, Name, read) =:= []])) end). recover_durable_queues(QueuesAndRecoveryTerms) -> |