summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2014-02-17 11:55:05 +0000
committerSimon MacMullen <simon@rabbitmq.com>2014-02-17 11:55:05 +0000
commit4a27eaa0c926ef94c45745514c1ea20366198f10 (patch)
treecc1e5c118547a03f400bfa0e98e5603459afbaa5
parentf1ddbda5b10f395f9bdb9bfa094012369df0689b (diff)
parentf4017ab867c0c607a72260b383e081fcde088202 (diff)
downloadrabbitmq-server-4a27eaa0c926ef94c45745514c1ea20366198f10.tar.gz
stable to default
-rw-r--r--docs/rabbitmq.config.example2
-rw-r--r--src/rabbit_binding.erl16
2 files changed, 10 insertions, 8 deletions
diff --git a/docs/rabbitmq.config.example b/docs/rabbitmq.config.example
index c0d6cc70..7d6b80a7 100644
--- a/docs/rabbitmq.config.example
+++ b/docs/rabbitmq.config.example
@@ -341,7 +341,7 @@
%% {reconnect_delay, 2.5}
%% ]} %% End of my_first_shovel
- ]},
+ ]}
%% Rather than specifying some values per-shovel, you can specify
%% them for all shovels here.
%%
diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl
index bb9c61a8..1b4a07e3 100644
--- a/src/rabbit_binding.erl
+++ b/src/rabbit_binding.erl
@@ -200,13 +200,15 @@ remove(Binding, InnerFun) ->
binding_action(
Binding,
fun (Src, Dst, B) ->
- case mnesia:read(rabbit_route, B, write) =:= [] andalso
- mnesia:read(rabbit_durable_route, B, write) =/= [] of
- true -> rabbit_misc:const({error, binding_not_found});
- false -> case InnerFun(Src, Dst) of
- ok -> remove(Src, Dst, B);
- {error, _} = Err -> rabbit_misc:const(Err)
- end
+ case mnesia:read(rabbit_route, B, write) of
+ [] -> case mnesia:read(rabbit_durable_route, B, write) of
+ [] -> rabbit_misc:const(ok);
+ _ -> rabbit_misc:const({error, binding_not_found})
+ end;
+ _ -> case InnerFun(Src, Dst) of
+ ok -> remove(Src, Dst, B);
+ {error, _} = Err -> rabbit_misc:const(Err)
+ end
end
end, fun absent_errs_only/1).