summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@lshift.net>2008-10-12 11:59:28 +0100
committerMatthias Radestock <matthias@lshift.net>2008-10-12 11:59:28 +0100
commitdde9b0795640dd4268eac5e958b13d1ff07ffa76 (patch)
tree60fa0d6a952fc3765bdb5297b18ca35e0e7bea42
parent9b415e6b132dbaac13da3e54e9a709898cd08a6f (diff)
downloadrabbitmq-server-dde9b0795640dd4268eac5e958b13d1ff07ffa76.tar.gz
some minor formatting fixes
-rw-r--r--src/rabbit_exchange.erl8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl
index 96d7dbe7..c8c4f0fc 100644
--- a/src/rabbit_exchange.erl
+++ b/src/rabbit_exchange.erl
@@ -278,7 +278,7 @@ continue(_) ->
call_with_exchange(Exchange, Fun) ->
rabbit_misc:execute_mnesia_transaction(
fun() -> case mnesia:read({exchange, Exchange}) of
- [] -> {error, exchange_not_found};
+ [] -> {error, exchange_not_found};
[X] -> Fun(X)
end
end).
@@ -287,7 +287,7 @@ call_with_exchange_and_queue(Exchange, Queue, Fun) ->
call_with_exchange(
Exchange,
fun(X) -> case mnesia:read({amqqueue, Queue}) of
- [] -> {error, queue_not_found};
+ [] -> {error, queue_not_found};
[Q] -> Fun(X, Q)
end
end).
@@ -319,7 +319,7 @@ sync_binding(ExchangeName, QueueName, RoutingKey, Durable, Fun) ->
queue_name = QueueName,
key = RoutingKey},
ok = case Durable of
- true -> Fun(durable_routes, #route{binding = Binding}, write);
+ true -> Fun(durable_routes, #route{binding = Binding}, write);
false -> ok
end,
[ok, ok] = [Fun(element(1, R), R, write) ||
@@ -392,7 +392,7 @@ maybe_auto_delete(Exchange = #exchange{auto_delete = true}) ->
conditional_delete(Exchange = #exchange{name = ExchangeName}) ->
case has_bindings(ExchangeName) of
false -> unconditional_delete(Exchange);
- true -> {error, in_use}
+ true -> {error, in_use}
end.
unconditional_delete(#exchange{name = ExchangeName}) ->