summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2011-05-05 11:18:19 +0100
committerSimon MacMullen <simon@rabbitmq.com>2011-05-05 11:18:19 +0100
commit9cd3070bd66344ddc1dc31b5fcf4ea2461cb0805 (patch)
tree5632bfc621d8274d9c608bc3ca6fd1f19961648f
parent18fe42a37a41ea8bc1878716077e9fe4e7c6cdea (diff)
downloadrabbitmq-server-bug23939.tar.gz
80 columns.bug23939
-rw-r--r--src/rabbit_binding.erl6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl
index 1944792e..2f71bfab 100644
--- a/src/rabbit_binding.erl
+++ b/src/rabbit_binding.erl
@@ -156,10 +156,12 @@ add(Src, Dst, B) ->
mnesia:read({rabbit_durable_route, B}) =:= []) of
true -> ok = sync_route(#route{binding = B}, SrcDurable, DstDurable,
fun mnesia:write/3),
- ok = rabbit_exchange:callback(Src, add_binding, [transaction, Src, B]),
+ ok = rabbit_exchange:callback(
+ Src, add_binding, [transaction, Src, B]),
Serial = rabbit_exchange:serial(Src),
fun () ->
- ok = rabbit_exchange:callback(Src, add_binding, [Serial, Src, B]),
+ ok = rabbit_exchange:callback(
+ Src, add_binding, [Serial, Src, B]),
ok = rabbit_event:notify(binding_created, info(B))
end;
false -> rabbit_misc:const({error, binding_not_found})