From 9d0204505ec91746ae7ad5898346064b6c8ed96f Mon Sep 17 00:00:00 2001
From: Matthias Radestock <matthias@rabbitmq.com>
Date: Fri, 15 Oct 2010 09:07:30 +0100
Subject: fire {exchange,binding}_deleted events

---
 src/rabbit_binding.erl | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/rabbit_binding.erl b/src/rabbit_binding.erl
index 53c9c663..1af213c4 100644
--- a/src/rabbit_binding.erl
+++ b/src/rabbit_binding.erl
@@ -426,10 +426,14 @@ merge_entry({X1, Deleted1, Bindings1}, {X2, Deleted2, Bindings2}) ->
 process_deletions(Deletions) ->
     dict:fold(
       fun (_XName, {X = #exchange{ type = Type }, Deleted, Bindings}, ok) ->
-              TypeModule = type_to_module(Type),
               FlatBindings = lists:flatten(Bindings),
+              [rabbit_event:notify(binding_deleted, info(B)) ||
+                  B <- FlatBindings],
+              TypeModule = type_to_module(Type),
               case Deleted of
                   not_deleted -> TypeModule:remove_bindings(X, FlatBindings);
-                  deleted     -> TypeModule:delete(X, FlatBindings)
+                  deleted     -> rabbit_event:notify(exchange_deleted,
+                                                     [{name, X#exchange.name}]),
+                                 TypeModule:delete(X, FlatBindings)
               end
       end, ok, Deletions).
-- 
cgit v1.2.1