summaryrefslogtreecommitdiff
path: root/src/rabbit_queue_consumers.erl
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2014-01-09 12:17:15 +0000
committerSimon MacMullen <simon@rabbitmq.com>2014-01-09 12:17:15 +0000
commitaf0265053ebae4ae006fd4cca2d66bf499dd26ef (patch)
tree03142171ba282db0cb02f4abde721015532910dc /src/rabbit_queue_consumers.erl
parent769872621b7982e4489f0f9d1781063d49803fa8 (diff)
downloadrabbitmq-server-af0265053ebae4ae006fd4cca2d66bf499dd26ef.tar.gz
More consistent naming
Diffstat (limited to 'src/rabbit_queue_consumers.erl')
-rw-r--r--src/rabbit_queue_consumers.erl4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_queue_consumers.erl b/src/rabbit_queue_consumers.erl
index 11c26f92..9dafa71a 100644
--- a/src/rabbit_queue_consumers.erl
+++ b/src/rabbit_queue_consumers.erl
@@ -120,7 +120,7 @@ count() -> lists:sum([Count || #cr{consumer_count = Count} <- all_ch_record()]).
unacknowledged_message_count() ->
lists:sum([queue:len(C#cr.acktags) || C <- all_ch_record()]).
-add(ChPid, ConsumerTag, NoAck, LimiterPid, LimiterActive, CreditArgs, OtherArgs,
+add(ChPid, ConsumerTag, NoAck, LimiterPid, LimiterActive, CreditArgs, Args,
IsEmpty, State = #state{consumers = Consumers}) ->
C = #cr{consumer_count = Count,
limiter = Limiter} = ch_record(ChPid, LimiterPid),
@@ -143,7 +143,7 @@ add(ChPid, ConsumerTag, NoAck, LimiterPid, LimiterActive, CreditArgs, OtherArgs,
end),
Consumer = #consumer{tag = ConsumerTag,
ack_required = not NoAck,
- args = OtherArgs},
+ args = Args},
State#state{consumers = add_consumer({ChPid, Consumer}, Consumers)}.
remove(ChPid, ConsumerTag, State = #state{consumers = Consumers}) ->