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

cosmetic rename 

for consistency with code in rabbit_exchange
This commit is contained in:
Matthias Radestock 2008-11-12 23:33:31 +00:00
parent 855ab46dc5
commit 6a613d1278
1 changed files with 16 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
src/rabbit_amqqueue_process.erl
View File

@ -476,42 +476,37 @@ purge_message_buffer(QName, MessageBuffer) ->
%% artifically ack them.
persist_acks(none, QName, lists:append(Messages)).
infos(Items, State) -> [{Item, info(Item, State)} || Item <- Items].
infos(Items, State) -> [{Item, i(Item, State)} || Item <- Items].
info(name, #q{q = #amqqueue{name = Name}}) ->
Name;
info(durable, #q{q = #amqqueue{durable = Durable}}) ->
Durable;
info(auto_delete, #q{q = #amqqueue{auto_delete = AutoDelete}}) ->
AutoDelete;
info(arguments, #q{q = #amqqueue{arguments = Arguments}}) ->
Arguments;
info(pid, #q{q = #amqqueue{pid = Pid}}) ->
Pid;
info(messages_ready, #q{message_buffer = MessageBuffer}) ->
i(name, #q{q = #amqqueue{name = Name}}) -> Name;
i(durable, #q{q = #amqqueue{durable = Durable}}) -> Durable;
i(auto_delete, #q{q = #amqqueue{auto_delete = AutoDelete}}) -> AutoDelete;
i(arguments, #q{q = #amqqueue{arguments = Arguments}}) -> Arguments;
i(pid, #q{q = #amqqueue{pid = Pid}}) -> Pid;
i(messages_ready, #q{message_buffer = MessageBuffer}) ->
queue:len(MessageBuffer);
info(messages_unacknowledged, _) ->
i(messages_unacknowledged, _) ->
lists:sum([dict:size(UAM) ||
#cr{unacked_messages = UAM} <- all_ch_record()]);
info(messages_uncommitted, _) ->
i(messages_uncommitted, _) ->
lists:sum([length(Pending) ||
#tx{pending_messages = Pending} <- all_tx_record()]);
info(messages, State) ->
lists:sum([info(Item, State) || Item <- [messages_ready,
i(messages, State) ->
lists:sum([i(Item, State) || Item <- [messages_ready,
messages_unacknowledged,
messages_uncommitted]]);
info(acks_uncommitted, _) ->
i(acks_uncommitted, _) ->
lists:sum([length(Pending) ||
#tx{pending_acks = Pending} <- all_tx_record()]);
info(consumers, _) ->
i(consumers, _) ->
lists:sum([length(Consumers) ||
#cr{consumers = Consumers} <- all_ch_record()]);
info(transactions, _) ->
i(transactions, _) ->
length(all_tx_record());
info(memory, _) ->
i(memory, _) ->
{memory, M} = process_info(self(), memory),
M;
info(Item, _) ->
i(Item, _) ->
throw({bad_argument, Item}).
%---------------------------------------------------------------------------