diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-03-30 12:15:20 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-03-30 12:15:20 +0100 |
| commit | 056f5467c9778017c97939ee7a911cffaa99cce9 (patch) | |
| tree | 89405fa9de0e4ee890da638cc0e64d2b74ac6138 /src | |
| parent | 065f2e7596ab1e27669c05c0b0be9469376f6559 (diff) | |
| download | rabbitmq-server-git-056f5467c9778017c97939ee7a911cffaa99cce9.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_binding.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl index 534233c1d9..2439d45597 100644 --- a/src/rabbit_binding.erl +++ b/src/rabbit_binding.erl @@ -410,11 +410,11 @@ process_deletions(Deletions) -> AugmentedDeletions = dict:map(fun (_XName, {X, deleted, Bindings}) -> Bs = lists:flatten(Bindings), - pd_callback(transaction, X, delete, Bs), + x_callback(transaction, X, delete, Bs), {X, deleted, Bs, none}; (_XName, {X, not_deleted, Bindings}) -> Bs = lists:flatten(Bindings), - pd_callback(transaction, X, remove_bindings, Bs), + x_callback(transaction, X, remove_bindings, Bs), {X, not_deleted, Bs, rabbit_exchange:serial(X)} end, Deletions), fun() -> @@ -422,13 +422,13 @@ process_deletions(Deletions) -> ok = rabbit_event:notify( exchange_deleted, [{name, XName}]), del_notify(Bs), - pd_callback(Serial, X, delete, Bs); + x_callback(Serial, X, delete, Bs); (_XName, {X, not_deleted, Bs, Serial}, ok) -> del_notify(Bs), - pd_callback(Serial, X, remove_bindings, Bs) + x_callback(Serial, X, remove_bindings, Bs) end, ok, AugmentedDeletions) end. del_notify(Bs) -> [rabbit_event:notify(binding_deleted, info(B)) || B <- Bs]. -pd_callback(Arg, X, F, Bs) -> ok = rabbit_exchange:callback(X, F, [Arg, X, Bs]). +x_callback(Arg, X, F, Bs) -> ok = rabbit_exchange:callback(X, F, [Arg, X, Bs]). |