summaryrefslogtreecommitdiff
path: root/src/rabbit_amqqueue.erl
diff options
context:
space:
mode:
authorEmile Joubert <emile@rabbitmq.com>2011-01-10 14:36:47 +0000
committerEmile Joubert <emile@rabbitmq.com>2011-01-10 14:36:47 +0000
commitc916d953626e1c8acb3cd74a8dfc08ef0a0c9e28 (patch)
tree0d44cde70958612bdf04d94184ffb0a1b8394b27 /src/rabbit_amqqueue.erl
parent831b609b58447daa4e40b192c836a6ecf92f896a (diff)
downloadrabbitmq-server-c916d953626e1c8acb3cd74a8dfc08ef0a0c9e28.tar.gz
More frugal use of thunks
Diffstat (limited to 'src/rabbit_amqqueue.erl')
-rw-r--r--src/rabbit_amqqueue.erl7
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) ->