diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-05-05 11:18:19 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-05-05 11:18:19 +0100 |
| commit | dcb584730bfc4a8b452b8b4a745970d544a2b039 (patch) | |
| tree | 5632bfc621d8274d9c608bc3ca6fd1f19961648f | |
| parent | 729ad3699262fa3966d410b8ed647ae5bac76053 (diff) | |
| download | rabbitmq-server-git-dcb584730bfc4a8b452b8b4a745970d544a2b039.tar.gz | |
80 columns.
| -rw-r--r-- | src/rabbit_binding.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl index 1944792ea5..2f71bfab63 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}) |
