diff options
| author | Tony Garnock-Jones <tonyg@kcbbs.gen.nz> | 2009-12-02 08:01:03 +0000 |
|---|---|---|
| committer | Tony Garnock-Jones <tonyg@kcbbs.gen.nz> | 2009-12-02 08:01:03 +0000 |
| commit | 26f823825509269e9c31de3c17969f33f5bedc23 (patch) | |
| tree | 176de4492f302f9d5197ffab4557e97a0ab8f301 /src | |
| parent | a01627c9acc9d7053a7112f66d49e2588d4205ae (diff) | |
| download | rabbitmq-server-git-26f823825509269e9c31de3c17969f33f5bedc23.tar.gz | |
Ignore any old records
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_exchange_events.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_exchange_events.erl b/src/rabbit_exchange_events.erl index b9dfef86b7..7764713574 100644 --- a/src/rabbit_exchange_events.erl +++ b/src/rabbit_exchange_events.erl @@ -58,14 +58,14 @@ with_exchange(#binding{exchange_name = ExchangeName}, Fun) -> ok end. -handle_table_event({write, rabbit_exchange, X = #exchange{type = Type}, [], _ActivityId}) -> +handle_table_event({write, rabbit_exchange, X = #exchange{type = Type}, _OldRecs, _ActivityId}) -> %% Exchange created/recovered. ok = Type:init(X); handle_table_event({delete, rabbit_exchange, {rabbit_exchange, _ExchangeName}, [X = #exchange{type = Type}], _ActivityId}) -> %% Exchange deleted. ok = Type:delete(X); -handle_table_event({write, rabbit_route, #route{binding = B}, [], _ActivityId}) -> +handle_table_event({write, rabbit_route, #route{binding = B}, _OldRecs, _ActivityId}) -> %% New binding. ok = with_exchange(B, fun (X = #exchange{type = Type}) -> Type:add_binding(X, B) end); handle_table_event({delete, rabbit_route, #route{binding = B}, _OldRecs, _ActivityId}) -> |