summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2011-04-01 11:07:51 +0100
committerSimon MacMullen <simon@rabbitmq.com>2011-04-01 11:07:51 +0100
commit7fc7f4ad96ca8198ddcc978fd5b54d26b1d0448e (patch)
tree03bd81ade66ca11b578cbc04bc7c8aa572e82c5a /src
parent3c7935e50c7fa405995111ba865e10a239ba7b8a (diff)
downloadrabbitmq-server-git-7fc7f4ad96ca8198ddcc978fd5b54d26b1d0448e.tar.gz
Dest -> Dst
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_binding.erl16
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