diff options
| -rw-r--r-- | src/rabbit_exchange.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl index b2b365ad43..9d3d6d5f2f 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -304,13 +304,13 @@ delete_queue_bindings(QueueName, FwdDeleteFun) -> none, [], []), fun () -> lists:foreach( - fun ({{auto_deleted, X = #exchange{ type = Type }}, Bs}) -> + fun ({{IsDeleted, X = #exchange{ type = Type }}, Bs}) -> Module = type_to_module(Type), [Module:delete_binding(X, B) || B <- Bs], - Module:delete(X, []); - ({{no_delete, X = #exchange{ type = Type }}, Bs}) -> - Module = type_to_module(Type), - [Module:delete_binding(X, B) || B <- Bs] + case IsDeleted of + auto_deleted -> Module:delete(X, []); + no_delete -> ok + end end, Cleanup) end. |