diff options
| author | Ben Hood <0x6e6562@gmail.com> | 2008-09-21 19:35:56 +0100 |
|---|---|---|
| committer | Ben Hood <0x6e6562@gmail.com> | 2008-09-21 19:35:56 +0100 |
| commit | f0190047621d29d0db72eeac113b5c00f08bf594 (patch) | |
| tree | bbd0e7a0da49faf8ef1af6952d0a0d02cd6f1b03 | |
| parent | 38543ca50f7483e0b170506c331f1608144a1e22 (diff) | |
| download | rabbitmq-server-f0190047621d29d0db72eeac113b5c00f08bf594.tar.gz | |
Got rid of no spaces after commas
| -rw-r--r-- | src/rabbit_exchange.erl | 8 | ||||
| -rw-r--r-- | src/rabbit_mnesia.erl | 6 |
2 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl index f4cab8da..52a6dbdd 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -223,13 +223,13 @@ route(#exchange{name = Name, type = topic}, RoutingKey) -> % Guards = [{'==', '$1', Name}, {'==', '$2', RoutingKey}], % ... route(#exchange{name = #resource{name = Name, virtual_host = VHostPath}}, RoutingKey) -> - Exchange = #resource{kind = exchange, name ='$1',virtual_host = '$2'}, + Exchange = #resource{kind = exchange, name ='$1', virtual_host = '$2'}, MatchHead = #route{binding = #binding{exchange_name = Exchange, queue_name = '$3', key = '$4'}}, Guards = [{'==', '$1', Name}, {'==', '$2', VHostPath}, {'==', '$4', RoutingKey}], lookup_qpids(mnesia:activity(async_dirty, - fun() -> mnesia:select(route,[{MatchHead, Guards, ['$3']}]) + fun() -> mnesia:select(route, [{MatchHead, Guards, ['$3']}]) end)). lookup_qpids(Queues) -> @@ -239,7 +239,7 @@ lookup_qpids(Queues) -> fun(Key, Acc) -> [#amqqueue{pid = QPid}] = mnesia:read({amqqueue, Key}), [QPid | Acc] end, [], Set) end, - mnesia:activity(async_dirty,Fun). + mnesia:activity(async_dirty, Fun). % TODO: Should all of the route and binding management not be refactored to it's own module % Especially seeing as unbind will have to be implemented for 0.91 ? @@ -259,7 +259,7 @@ call_with_exchange_and_queue(#binding{exchange_name = Exchange, case mnesia:wread({amqqueue, Queue}) of [] -> {error, queue_not_found}; [Q] -> - Fun(X,Q) + Fun(X, Q) end end. diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl index 958c380b..bf532757 100644 --- a/src/rabbit_mnesia.erl +++ b/src/rabbit_mnesia.erl @@ -106,11 +106,11 @@ table_definitions() -> {listener, [{type, bag}, {attributes, record_info(fields, listener)}]}, {durable_routes, [{disc_copies, [node()]}, - {type,ordered_set}, + {type, ordered_set}, {record_name, route}, {attributes, record_info(fields, route)}]}, - {route, [{type,ordered_set},{attributes, record_info(fields, route)}]}, - {reverse_route, [{type,ordered_set},{attributes, record_info(fields, reverse_route)}]}, + {route, [{type, ordered_set}, {attributes, record_info(fields, route)}]}, + {reverse_route, [{type, ordered_set}, {attributes, record_info(fields, reverse_route)}]}, {durable_exchanges, [{disc_copies, [node()]}, {record_name, exchange}, {attributes, record_info(fields, exchange)}]}, |