root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Got rid of no spaces after commas

This commit is contained in:
Ben Hood 2008-09-21 19:35:56 +01:00
parent c7e97fab2b
commit 76ddf664cb
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/rabbit_exchange.erl
View File

@ -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.

6
src/rabbit_mnesia.erl
View File

@ -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)}]},