diff options
author | Emile Joubert <emile@rabbitmq.com> | 2011-01-10 14:36:47 +0000 |
---|---|---|
committer | Emile Joubert <emile@rabbitmq.com> | 2011-01-10 14:36:47 +0000 |
commit | c916d953626e1c8acb3cd74a8dfc08ef0a0c9e28 (patch) | |
tree | 0d44cde70958612bdf04d94184ffb0a1b8394b27 /src/rabbit_amqqueue.erl | |
parent | 831b609b58447daa4e40b192c836a6ecf92f896a (diff) | |
download | rabbitmq-server-c916d953626e1c8acb3cd74a8dfc08ef0a0c9e28.tar.gz |
More frugal use of thunks
Diffstat (limited to 'src/rabbit_amqqueue.erl')
-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 82c1f454..ba8ce6da 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -213,14 +213,13 @@ declare(QueueName, Durable, AutoDelete, Args, Owner) -> end. internal_declare(Q = #amqqueue{name = QueueName}, Recover) -> - EmptyFun = fun (_) -> ok end, rabbit_misc:execute_mnesia_tx_with_tail( fun () -> {ReturnArg, TailFun} = case Recover of true -> ok = store_queue(Q), - {Q, EmptyFun}; + {Q, fun rabbit_misc:const_ok/1}; false -> case mnesia:wread({rabbit_queue, QueueName}) of [] -> @@ -230,10 +229,10 @@ internal_declare(Q = #amqqueue{name = QueueName}, Recover) -> B = add_default_binding(Q), {Q, B}; %% Q exists on stopped node - [_] -> {not_found, EmptyFun} + [_] -> {not_found, fun rabbit_misc:const_ok/1} end; [ExistingQ] -> - {ExistingQ, EmptyFun} + {ExistingQ, fun rabbit_misc:const_ok/1} end end, fun (Tx) -> |