diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-03-28 22:13:57 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-03-28 22:13:57 +0100 |
| commit | 4501e6ba879c9238f3960816cf8e7e5b8f6cf204 (patch) | |
| tree | d985906d50182b8bc2c5504ead050c57fc3b43c7 | |
| parent | 530884ca4d82fb3a8bb1b34d0f080d8ccf4ca4b1 (diff) | |
| download | rabbitmq-server-git-4501e6ba879c9238f3960816cf8e7e5b8f6cf204.tar.gz | |
index the serial dict by XName rather than X
...which should be more efficient
| -rw-r--r-- | src/rabbit_binding.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl index b6324bb53d..3bf8e6a94c 100644 --- a/src/rabbit_binding.erl +++ b/src/rabbit_binding.erl @@ -408,16 +408,16 @@ merge_entry({X1, Deleted1, Bindings1}, {X2, Deleted2, Bindings2}) -> process_deletions(Deletions) -> Serials = dict:fold( - fun (_XName, {X, Deleted, Bindings}, Acc) -> + fun (XName, {X, Deleted, Bindings}, Acc) -> FlatBindings = lists:flatten(Bindings), pd_callback(transaction, X, Deleted, FlatBindings), - dict:store(X, rabbit_exchange:serial(X), Acc) + dict:store(XName, rabbit_exchange:serial(X), Acc) end, Deletions, dict:new()), fun() -> dict:fold( fun (XName, {X, Deleted, Bindings}, ok) -> FlatBindings = lists:flatten(Bindings), - Serial = dict:fetch(X, Serials), + Serial = dict:fetch(XName, Serials), pd_callback(Serial, X, Deleted, FlatBindings), [rabbit_event:notify(binding_deleted, info(B)) || B <- FlatBindings], |