diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-04-01 11:07:51 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-04-01 11:07:51 +0100 |
| commit | 7fc7f4ad96ca8198ddcc978fd5b54d26b1d0448e (patch) | |
| tree | 03bd81ade66ca11b578cbc04bc7c8aa572e82c5a /src | |
| parent | 3c7935e50c7fa405995111ba865e10a239ba7b8a (diff) | |
| download | rabbitmq-server-git-7fc7f4ad96ca8198ddcc978fd5b54d26b1d0448e.tar.gz | |
Dest -> Dst
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_binding.erl | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl index 0263144a02..26eb78fb20 100644 --- a/src/rabbit_binding.erl +++ b/src/rabbit_binding.erl @@ -112,13 +112,13 @@ recover(XsL, QsL) -> end end, [], rabbit_semi_durable_route). -should_recover(B = #binding{destination = Dest = #resource{ kind = Kind }}, +should_recover(B = #binding{destination = Dst = #resource{ kind = Kind }}, XNames, QNames) -> case mnesia:read({rabbit_route, B}) of - [] -> sets:is_element(Dest, case Kind of - exchange -> XNames; - queue -> QNames - end); + [] -> sets:is_element(Dst, case Kind of + exchange -> XNames; + queue -> QNames + end); _ -> false end. @@ -281,13 +281,13 @@ binding_action(Binding = #binding{source = SrcName, Fun(Src, Dst, Binding#binding{args = SortedArgs}) end). -sync_binding(Binding, Src, Dest, Fun) -> +sync_binding(Binding, Src, Dst, Fun) -> {Route, ReverseRoute} = route_with_reverse(Binding), - ok = case all_durable([Src, Dest]) of + ok = case all_durable([Src, Dst]) of true -> Fun(rabbit_durable_route, Route, write); false -> ok end, - ok = case Dest of + ok = case Dst of #amqqueue{durable = true} -> Fun(rabbit_semi_durable_route, Route, write); _ -> ok |
