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 | 49444ced98f0bad66a788db1b0e10773ac346b9e (patch) | |
| tree | 89405fa9de0e4ee890da638cc0e64d2b74ac6138 /src | |
| parent | 77d54c95c8e90f1329a5f876497db617921a8ae2 (diff) | |
| download | rabbitmq-server-49444ced98f0bad66a788db1b0e10773ac346b9e.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 534233c1..2439d455 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]). |