summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2011-04-09 00:15:52 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2011-04-09 00:15:52 +0100
commit4499806171ae66cbb08b02a4309e876ff5efc0d7 (patch)
tree974dd07ef005067cb2bc53d59489da19f2428e42
parent9456939f2ad57435fa19975bc552762ed722d83b (diff)
downloadrabbitmq-server-4499806171ae66cbb08b02a4309e876ff5efc0d7.tar.gz
tiny refactor
-rw-r--r--src/rabbit_binding.erl11
1 files changed, 5 insertions, 6 deletions
diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl
index 0fb0639a..b0a59a0c 100644
--- a/src/rabbit_binding.erl
+++ b/src/rabbit_binding.erl
@@ -281,17 +281,16 @@ sync_transient_binding(Binding, Fun) ->
call_with_source_and_destination(SrcName, DstName, Fun) ->
SrcTable = table_for_resource(SrcName),
DstTable = table_for_resource(DstName),
- ErrFun = fun (Err) -> rabbit_misc:const(Err) end,
+ ErrFun = fun (Err) -> rabbit_misc:const({error, Err}) end,
rabbit_misc:execute_mnesia_tx_with_tail(
fun () ->
case {mnesia:read({SrcTable, SrcName}),
mnesia:read({DstTable, DstName})} of
{[Src], [Dst]} -> Fun(Src, Dst);
- {[], [_] } -> ErrFun({error, source_not_found});
- {[_], [] } -> ErrFun({error, destination_not_found});
- {[], [] } -> ErrFun({error,
- source_and_destination_not_found})
- end
+ {[], [_] } -> ErrFun(source_not_found);
+ {[_], [] } -> ErrFun(destination_not_found);
+ {[], [] } -> ErrFun(source_and_destination_not_found)
+ end
end).
table_for_resource(#resource{kind = exchange}) -> rabbit_exchange;