diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-06-30 17:51:25 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-06-30 17:51:25 +0100 |
| commit | 493de8971b5c61c138b8cbfc90e3e89bec629b43 (patch) | |
| tree | 1553b6484ec43c7a23ea1831369b772503b5ad3c | |
| parent | 9e896c4f76311cfd2ef935ee8304bffe5bd730f7 (diff) | |
| parent | e20219f2a80ba4d242db374d17722f2bb63b67d9 (diff) | |
| download | rabbitmq-server-git-493de8971b5c61c138b8cbfc90e3e89bec629b43.tar.gz | |
Merging bug 22918 into default
| -rw-r--r-- | src/rabbit_exchange.erl | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl index 7072055cde..d77bf833ea 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -335,7 +335,7 @@ delete_queue_bindings(QueueName, FwdDeleteFun) -> Module = type_to_module(Type), case IsDeleted of auto_deleted -> Module:delete(X, Bs); - no_delete -> Module:remove_bindings(X, Bs) + not_deleted -> Module:remove_bindings(X, Bs) end end, Cleanup) end. @@ -438,11 +438,11 @@ delete_binding(ExchangeName, QueueName, RoutingKey, Arguments, InnerFun) -> end) of Err = {error, _} -> Err; - {{Action, X = #exchange{ type = Type }}, B} -> + {{IsDeleted, X = #exchange{ type = Type }}, B} -> Module = type_to_module(Type), - case Action of - auto_delete -> Module:delete(X, [B]); - no_delete -> Module:remove_bindings(X, [B]) + case IsDeleted of + auto_deleted -> Module:delete(X, [B]); + not_deleted -> Module:remove_bindings(X, [B]) end end. @@ -526,10 +526,10 @@ delete(ExchangeName, IfUnused) -> end. maybe_auto_delete(Exchange = #exchange{auto_delete = false}) -> - {no_delete, Exchange}; + {not_deleted, Exchange}; maybe_auto_delete(Exchange = #exchange{auto_delete = true}) -> case conditional_delete(Exchange) of - {error, in_use} -> {no_delete, Exchange}; + {error, in_use} -> {not_deleted, Exchange}; {deleted, Exchange, []} -> {auto_deleted, Exchange} end. |
